Modifier and Type | Method and Description |
---|---|
default Stream<List<T>> |
Stream.buffer(int size) |
default Stream<List<T>> |
Stream.buffer(int size,
int step) |
default Stream<List<T>> |
Stream.bufferUntil(BiPredicate<? super List<T>,? super T> condition,
boolean emitRemainder) |
default Stream<List<T>> |
Stream.bufferUntil(BiPredicate<? super List<T>,? super T> condition,
boolean emitRemainder,
Function<? super List<T>,Integer> step,
int maxReplay) |
default Stream<List<T>> |
Stream.bufferUntil(BiPredicate<? super List<T>,? super T> condition,
boolean emitRemainder,
int step,
int maxReplay) |
default <S> Stream<S> |
Stream.bufferUntil(Callable<? extends S> factory,
BiFunction<? super S,? super T,? extends S> accumulator,
BiPredicate<? super S,? super T> condition,
boolean emitRemainder,
Function<? super S,Integer> step,
int maxReplay) |
default Stream<List<T>> |
Stream.bufferWhile(BiPredicate<? super List<T>,? super T> condition,
boolean emitRemainder) |
default Stream<List<T>> |
Stream.bufferWhile(BiPredicate<? super List<T>,? super T> condition,
boolean emitRemainder,
Function<? super List<T>,Integer> step,
int maxReplay) |
default Stream<List<T>> |
Stream.bufferWhile(BiPredicate<? super List<T>,? super T> condition,
boolean emitRemainder,
int step,
int maxReplay) |
default <S> Stream<S> |
Stream.bufferWhile(Callable<? extends S> factory,
BiFunction<? super S,? super T,? extends S> accumulator,
BiPredicate<? super S,? super T> condition,
boolean emitRemainder,
Function<? super S,Integer> step,
int maxReplay) |
Stream<T> |
RetryWhenBuilder.build() |
static Stream<ByteBuffer> |
Stream.byteBuffers(Callable<? extends InputStream> provider) |
static Stream<ByteBuffer> |
Stream.byteBuffers(Callable<? extends InputStream> provider,
int bufferSize) |
static Stream<ByteBuffer> |
Stream.byteBuffers(InputStream in) |
static Stream<ByteBuffer> |
Stream.byteBuffers(InputStream in,
int bufferSize) |
static Stream<byte[]> |
Stream.bytes(Callable<? extends InputStream> provider) |
static Stream<byte[]> |
Stream.bytes(Callable<? extends InputStream> provider,
int bufferSize) |
static Stream<byte[]> |
Stream.bytes(InputStream in) |
static Stream<byte[]> |
Stream.bytes(InputStream in,
int bufferSize) |
default Stream<T> |
Stream.cache() |
default <R> Stream<R> |
Stream.cast(Class<R> cls) |
static Stream<Integer> |
Stream.chars(CharSequence s) |
static Stream<Integer> |
Stream.chars(CharSequence s,
int fromIndex,
int toIndex) |
default <R> Stream<R> |
Stream.compose(Function<? super Stream<T>,? extends Stream<? extends R>> transformer) |
default Stream<T> |
Stream.concatWith(StreamIterable<? extends T> values) |
static <T> Stream<T> |
Stream.create(Iterable<? extends T> source) |
static <T> Stream<T> |
Stream.defer(Callable<? extends Stream<? extends T>> provider) |
default Stream<T> |
Stream.delayStart(long duration,
TimeUnit unit) |
default <R> Stream<R> |
Stream.dematerialize(Function<? super T,Notification<? extends R>> function) |
default Stream<T> |
Stream.distinct() |
default <K> Stream<T> |
Stream.distinct(Function<? super T,K> keySelector) |
default Stream<T> |
Stream.distinctUntilChanged() |
default <K> Stream<T> |
Stream.distinctUntilChanged(Function<? super T,K> keySelector) |
default Stream<T> |
Stream.doAfterDispose(Action action) |
default Stream<T> |
Stream.doBeforeDispose(Action action) |
default Stream<T> |
Stream.doOnComplete(Action action) |
default Stream<T> |
Stream.doOnDispose(Action action) |
default Stream<T> |
Stream.doOnEmpty(Action action) |
default Stream<T> |
Stream.doOnError(Consumer<? super Throwable> consumer) |
default Stream<T> |
Stream.doOnNext(Consumer<? super T> consumer) |
default Stream<T> |
Stream.doOnStart(Action action) |
default Stream<T> |
Stream.doWithIndex(BiConsumer<? super Long,? super T> consumer) |
static <T> Stream<T> |
Stream.empty() |
static <T> Stream<T> |
Stream.error(Callable<? extends Throwable> callable) |
static <T> Stream<T> |
Stream.error(Throwable e) |
default Stream<T> |
Stream.every(long n,
BiConsumer<Long,T> action) |
default Stream<T> |
Stream.filter(Predicate<? super T> function) |
default <R> Stream<R> |
Stream.flatMap(BiConsumer<? super T,? super Consumer<R>> generator)
Using a consumer to report items to downstream is more performant (fewer
allocations) because a Stream object doesn't have to be created for each
upstream element.
|
default <R> Stream<R> |
Stream.flatMap(BiConsumer<? super T,? super Consumer<R>> generator,
Consumer<? super Consumer<R>> onFinish) |
default <R> Stream<R> |
Single.flatMap(Function<? super T,? extends StreamIterable<? extends R>> mapper) |
default <R> Stream<R> |
Stream.flatMap(Function<? super T,? extends StreamIterable<? extends R>> function) |
default <R> Stream<R> |
Maybe.flatMap(Function<? super T,? extends StreamIterable<? extends R>> mapper) |
default <R> Stream<R> |
Stream.flatMapJavaStream(Function<? super T,? extends Stream<? extends R>> function) |
static Stream<String> |
Stream.from(InputStream in) |
static Stream<String> |
Stream.from(InputStream in,
Charset charset) |
static Stream<String> |
Stream.from(InputStream in,
Charset charset,
int bufferSize) |
static <T> Stream<T> |
Stream.from(Iterable<? extends T> iterable) |
static Stream<String> |
Stream.from(Reader reader) |
static Stream<String> |
Stream.from(Reader reader,
int bufferSize) |
static <T> Stream<T> |
Stream.from(Stream<? extends T> stream) |
static Stream<Double> |
Stream.fromArray(double[] array) |
static Stream<Double> |
Stream.fromArray(double[] array,
int fromIndex,
int toIndex) |
static Stream<Float> |
Stream.fromArray(float[] array) |
static Stream<Float> |
Stream.fromArray(float[] array,
int fromIndex,
int toIndex) |
static Stream<Integer> |
Stream.fromArray(int[] array) |
static Stream<Integer> |
Stream.fromArray(int[] array,
int fromIndex,
int toIndex) |
static <T> Stream<T> |
Stream.fromArray(T[] array) |
static <T> Stream<T> |
Stream.fromArray(T[] array,
int fromIndex,
int toIndex) |
static <T,R> Stream<T> |
Stream.generate(Callable<R> factory,
BiConsumer<R,Emitter<T>> consumer) |
static <T> Stream<T> |
Stream.generate(Consumer<Emitter<T>> consumer) |
default Stream<T> |
Stream.ignoreDisposalError() |
default Stream<T> |
Stream.ignoreDisposalError(Consumer<? super Throwable> action) |
static Stream<Integer> |
Stream.interval(long duration,
TimeUnit unit)
Emits the integers 0, 1, 2, ....
|
static Stream<String> |
Stream.lines(BufferedReader reader) |
static Stream<String> |
Stream.lines(Callable<? extends BufferedReader> readerFactory) |
static Stream<String> |
Stream.lines(Callable<? extends InputStream> inFactory,
Charset charset) |
static Stream<String> |
Stream.lines(File file) |
static Stream<String> |
Stream.lines(File file,
Charset charset) |
static Stream<String> |
Stream.linesFromResource(Class<?> cls,
String resource,
Charset charset) |
static Stream<String> |
Stream.linesFromResource(String resource) |
static Stream<String> |
Stream.linesFromResource(String resource,
Charset charset) |
default <R> Stream<R> |
Stream.map(Function<? super T,? extends R> function) |
default Stream<Indexed<T>> |
Stream.mapWithIndex() |
default Stream<Indexed<T>> |
Stream.mapWithIndex(int startIndex) |
default Stream<Notification<T>> |
Stream.materialize() |
static <T> Stream<T> |
Stream.merge(Stream<? extends T>... streams)
Returns an interleaved merge of the streams (one item emitted from each
stream in round-robin style).
|
default Stream<T> |
Stream.mergeWith(Stream<? extends T> stream) |
static <T> Stream<T> |
Stream.of(T t) |
static <T> Stream<T> |
Stream.of(T t1,
T t2) |
static <T> Stream<T> |
Stream.of(T t1,
T t2,
T t3) |
static <T> Stream<T> |
Stream.of(T t1,
T t2,
T t3,
T t4) |
static <T> Stream<T> |
Stream.of(T t1,
T t2,
T t3,
T t4,
T t5) |
static <T> Stream<T> |
Stream.of(T t1,
T t2,
T t3,
T t4,
T t5,
T t6) |
static <T> Stream<T> |
Stream.of(T t1,
T t2,
T t3,
T t4,
T t5,
T t6,
T t7) |
static <T> Stream<T> |
Stream.of(T t1,
T t2,
T t3,
T t4,
T t5,
T t6,
T t7,
T t8) |
static Stream<Integer> |
Stream.ordinals() |
static Stream<Long> |
Stream.ordinalsLong() |
static <T> Stream<List<Integer>> |
Stream.permutations(int size) |
static Stream<Set<Integer>> |
Stream.powerSet(int n) |
default Stream<T> |
Stream.prepend(StreamIterable<? extends T> values) |
default Stream<T> |
Stream.prepend(T value) |
default Stream<T> |
Stream.prepend(T[] values) |
default Stream<T> |
Stream.println() |
default Stream<T> |
Stream.printStackTrace() |
static Stream<Integer> |
Stream.range(int start,
int length) |
static Stream<Long> |
Stream.rangeLong(long start,
long length) |
default Stream<T> |
Single.repeat() |
default Stream<T> |
Stream.repeat() |
default Stream<T> |
Stream.repeat(long count) |
static <T> Stream<T> |
Stream.repeatElement(T t) |
static <T> Stream<T> |
Stream.repeatElement(T t,
long count) |
default Stream<T> |
Stream.repeatLast() |
default Stream<T> |
Stream.repeatLast(long count) |
default Stream<T> |
Stream.retryWhen(Function<? super Throwable,? extends Single<?>> function) |
default Stream<T> |
Stream.reverse() |
default <R> Stream<R> |
Stream.scan(R initialValue,
BiFunction<? super R,? super T,? extends R> accumulator) |
default Stream<T> |
Stream.skip(int size) |
default Stream<T> |
Stream.skipUntil(Predicate<? super T> predicate) |
default Stream<T> |
Stream.skipWhile(Predicate<? super T> predicate) |
default Stream<T> |
Stream.sorted() |
default Stream<T> |
Stream.sorted(Comparator<? super T> comparator) |
default Stream<String> |
Stream.split(String delimiter) |
static Stream<String> |
Stream.strings(Stream<? extends byte[]> stream) |
static Stream<String> |
Stream.strings(Stream<? extends byte[]> stream,
Charset charset) |
static Stream<String> |
Stream.strings(Stream<? extends byte[]> stream,
Charset charset,
int bufferSize) |
default Stream<T> |
Stream.switchOnEmpty(Callable<? extends Stream<T>> factory) |
default Stream<T> |
Stream.switchOnError(Function<? super Throwable,? extends Stream<? extends T>> function) |
default Stream<T> |
Stream.take(long n) |
default Stream<T> |
Stream.takeLast(long n) |
default Stream<T> |
Stream.takeUntil(Predicate<? super T> predicate) |
default Stream<T> |
Stream.takeWhile(Predicate<? super T> predicate) |
default Stream<T> |
Single.toStream() |
default Stream<T> |
Maybe.toStream() |
default <R> Stream<R> |
Stream.transform(Function<? super Stream<T>,? extends Stream<? extends R>> transformer) |
static <R extends Closeable,T> |
Stream.using(Callable<? extends R> resourceFactory,
Function<? super R,? extends Stream<? extends T>> streamFactory) |
static <R,T> Stream<T> |
Stream.using(Callable<? extends R> resourceFactory,
Function<? super R,? extends Stream<? extends T>> streamFactory,
Consumer<? super R> closer) |
default <R,S> Stream<S> |
Stream.zipWith(Stream<? extends R> stream,
BiFunction<T,R,S> combiner) |
Modifier and Type | Method and Description |
---|---|
RetryWhenBuilderMaybe<T> |
RetryWhenBuilderMaybe.delays(Stream<Long> delays,
TimeUnit unit) |
RetryWhenBuilderSingle<T> |
RetryWhenBuilderSingle.delays(Stream<Long> delays,
TimeUnit unit) |
RetryWhenBuilder<T> |
RetryWhenBuilder.delays(Stream<Long> delays,
TimeUnit unit) |
static InputStream |
Stream.inputStream(Stream<? extends byte[]> stream) |
static <T> Stream<T> |
Stream.merge(Stream<? extends T>... streams)
Returns an interleaved merge of the streams (one item emitted from each
stream in round-robin style).
|
default Stream<T> |
Stream.mergeWith(Stream<? extends T> stream) |
static <T extends Number> |
Stream.statistics(Stream<T> stream) |
static Stream<String> |
Stream.strings(Stream<? extends byte[]> stream) |
static Stream<String> |
Stream.strings(Stream<? extends byte[]> stream,
Charset charset) |
static Stream<String> |
Stream.strings(Stream<? extends byte[]> stream,
Charset charset,
int bufferSize) |
default <R,S> Stream<S> |
Stream.zipWith(Stream<? extends R> stream,
BiFunction<T,R,S> combiner) |
Modifier and Type | Method and Description |
---|---|
default <R> Stream<R> |
Stream.compose(Function<? super Stream<T>,? extends Stream<? extends R>> transformer) |
default <R> Stream<R> |
Stream.compose(Function<? super Stream<T>,? extends Stream<? extends R>> transformer) |
default <R> Maybe<R> |
Stream.composeMaybe(Function<? super Stream<T>,? extends Maybe<? extends R>> transformer) |
default <R> Single<R> |
Stream.composeSingle(Function<? super Stream<T>,? extends Single<? extends R>> transformer) |
static <T> Stream<T> |
Stream.defer(Callable<? extends Stream<? extends T>> provider) |
default Stream<T> |
Stream.switchOnEmpty(Callable<? extends Stream<T>> factory) |
default Stream<T> |
Stream.switchOnError(Function<? super Throwable,? extends Stream<? extends T>> function) |
default <R> R |
Stream.to(Function<? super Stream<T>,R> mapper) |
default <R> Stream<R> |
Stream.transform(Function<? super Stream<T>,? extends Stream<? extends R>> transformer) |
default <R> Stream<R> |
Stream.transform(Function<? super Stream<T>,? extends Stream<? extends R>> transformer) |
default <R> Maybe<R> |
Stream.transformMaybe(Function<? super Stream<T>,? extends Maybe<? extends R>> transformer) |
default <R> Single<R> |
Stream.transformSingle(Function<? super Stream<T>,? extends Single<? extends R>> transformer) |
static <R extends Closeable,T> |
Stream.using(Callable<? extends R> resourceFactory,
Function<? super R,? extends Stream<? extends T>> streamFactory) |
static <R,T> Stream<T> |
Stream.using(Callable<? extends R> resourceFactory,
Function<? super R,? extends Stream<? extends T>> streamFactory,
Consumer<? super R> closer) |
Constructor and Description |
---|
RetryWhenBuilder(Stream<T> stream) |
Tester(Stream<T> stream) |
Modifier and Type | Class and Description |
---|---|
class |
MaybeFlatMap<T,R> |
class |
MaybeToStream<T> |
Modifier and Type | Class and Description |
---|---|
class |
SingleFlatMap<T,R> |
class |
SingleToStream<T> |
Modifier and Type | Method and Description |
---|---|
static <T> Stream<T> |
RetryWhen.build(Stream<T> stream,
Stream<Long> delays,
int maxRetries,
Predicate<? super Throwable> predicate) |
Modifier and Type | Method and Description |
---|---|
static <T> Stream<T> |
RetryWhen.build(Stream<T> stream,
Stream<Long> delays,
int maxRetries,
Predicate<? super Throwable> predicate) |
static <T> Stream<T> |
RetryWhen.build(Stream<T> stream,
Stream<Long> delays,
int maxRetries,
Predicate<? super Throwable> predicate) |
Constructor and Description |
---|
All(Stream<T> stream,
Predicate<? super T> predicate) |
Any(Stream<T> stream,
Predicate<? super T> predicate) |
Buffer(Stream<T> stream,
int size,
int step) |
BufferWithFactoryPredicateAndStep(Callable<? extends S> factory,
BiFunction<? super S,? super T,? extends S> accumulator,
BiPredicate<? super S,? super T> condition,
boolean emitRemainder,
boolean until,
Stream<T> source,
Function<? super S,Integer> step,
int maxReplay) |
BufferWithPredicate(BiPredicate<? super List<T>,? super T> condition,
boolean emitRemainder,
boolean until,
Stream<T> source) |
Cache(Stream<T> stream) |
Collect(Callable<? extends R> factory,
BiConsumer<? super R,? super T> collector,
Stream<T> source) |
Count(Stream<?> stream) |
Dematerialize(Stream<T> stream,
Function<? super T,Notification<? extends R>> function) |
Distinct(Stream<T> stream,
Function<? super T,K> keySelector) |
DistinctUntilChanged(Stream<T> stream,
Function<? super T,K> keySelector) |
DoOnComplete(Action action,
Stream<T> source) |
DoOnDispose(Action action,
Stream<T> source,
boolean before) |
DoOnEmpty(Stream<T> stream,
Action action) |
DoOnError(Consumer<? super Throwable> consumer,
Stream<T> source) |
DoOnStart(Stream<T> stream,
Action action) |
FlatMapGenerator(BiConsumer<? super T,? super Consumer<R>> generator,
Consumer<? super Consumer<R>> onFinish,
Stream<T> stream) |
IgnoreDisposalError(Stream<T> stream,
Consumer<? super Throwable> consumer) |
IsEmpty(Stream<?> source) |
Materialize(Stream<T> stream) |
Max(Stream<T> stream,
Comparator<? super T> comparator,
boolean not) |
MergeInterleaved(Stream<? extends T>... streams) |
Repeat(long count,
Stream<T> source) |
RepeatLast(Stream<T> stream,
long count) |
RetryWhen(Stream<T> stream,
Function<? super Throwable,? extends Single<?>> function) |
Reverse(Stream<T> stream) |
Skip(int count,
Stream<T> source) |
SkipUntil(Stream<T> stream,
Predicate<? super T> predicate,
boolean negate) |
Sorted(Comparator<? super T> comparator,
Stream<T> source) |
Split(String delimiter,
Stream<?> source) |
SwitchOnEmpty(Stream<T> stream,
Callable<? extends Stream<T>> factory) |
SwitchOnError(Function<? super Throwable,? extends StreamIterable<? extends T>> function,
Stream<T> source) |
TakeLast(Stream<T> stream,
long n) |
TakeWithPredicate(Predicate<? super T> predicate,
Stream<T> source,
boolean until) |
ToMaybe(Stream<T> stream) |
ToSingle(Stream<T> stream) |
Transform(Function<? super Stream<T>,? extends Stream<? extends R>> transformer,
Stream<T> source) |
TransformMaybe(Function<? super Stream<T>,? extends Maybe<? extends R>> transformer,
Stream<T> stream) |
TransformSingle(Function<? super Stream<T>,? extends Single<? extends R>> transformer,
Stream<T> stream) |
Zip(Stream<T> source1,
Stream<? extends R> source2,
BiFunction<T,R,S> combiner) |
Zip(Stream<T> source1,
Stream<? extends R> source2,
BiFunction<T,R,S> combiner) |
Constructor and Description |
---|
Defer(Callable<? extends Stream<? extends T>> provider) |
SwitchOnEmpty(Stream<T> stream,
Callable<? extends Stream<T>> factory) |
Transform(Function<? super Stream<T>,? extends Stream<? extends R>> transformer,
Stream<T> source) |
Transform(Function<? super Stream<T>,? extends Stream<? extends R>> transformer,
Stream<T> source) |
TransformMaybe(Function<? super Stream<T>,? extends Maybe<? extends R>> transformer,
Stream<T> stream) |
TransformSingle(Function<? super Stream<T>,? extends Single<? extends R>> transformer,
Stream<T> stream) |
Using(Callable<? extends R> resourceFactory,
Function<? super R,? extends Stream<? extends T>> streamFactory,
Consumer<? super R> closer) |
Modifier and Type | Class and Description |
---|---|
class |
EmptyStream |
class |
StreamImpl<T> |
Modifier and Type | Field and Description |
---|---|
static Stream<Object> |
StreamUtils.EmptyHolder.EMPTY |
Modifier and Type | Method and Description |
---|---|
static InputStream |
StreamUtils.toInputStream(Stream<? extends byte[]> stream) |
Modifier and Type | Method and Description |
---|---|
Stream<LazyArrayNode> |
JsonArray.arrayNodes() |
Stream<com.fasterxml.jackson.databind.JsonNode> |
JsonArray.field(String name) |
Stream<com.fasterxml.jackson.core.JsonParser> |
Json.get() |
<T> Stream<LazyTreeNode> |
JsonArray.nodes() |
Stream<LazyObjectNode> |
JsonArray.objectNodes() |
Stream<LazyValueNode> |
JsonArray.valueNodes() |
Stream<com.fasterxml.jackson.databind.JsonNode> |
LazyArrayNode.values() |
<T> Stream<T> |
LazyArrayNode.values(Class<T> cls) |
Copyright © 2018–2023. All rights reserved.