PushStream<T> |
AbstractPushStreamImpl.adjustBackPressure(java.util.function.LongUnaryOperator adjustment) |
|
PushStream<T> |
AbstractPushStreamImpl.adjustBackPressure(java.util.function.ToLongBiFunction<T,java.lang.Long> adjustment) |
|
PushStream<T> |
PushStream.adjustBackPressure(java.util.function.LongUnaryOperator adjustment) |
Changes the back-pressure propagated by this pipeline stage.
|
PushStream<T> |
PushStream.adjustBackPressure(java.util.function.ToLongBiFunction<T,java.lang.Long> adjustment) |
Changes the back-pressure propagated by this pipeline stage.
|
<R> PushStream<R> |
AbstractPushStreamImpl.asyncMap(int n,
int delay,
Function<? super T,Promise<? extends R>> mapper) |
|
<R> PushStream<R> |
PushStream.asyncMap(int n,
int delay,
Function<? super T,Promise<? extends R>> mapper) |
Asynchronously map the payload values.
|
PushStream<T> |
AbstractPushStreamImpl.buffer() |
|
PushStream<T> |
PushStream.buffer() |
Buffer the events in a queue using default values for the queue size and
other behaviors.
|
PushStream<T> |
PushStreamBuilderImpl.build() |
|
private <T> PushStream<T> |
PushStreamProvider.cleanupThreads(boolean closeExecutorOnClose,
java.util.concurrent.Executor workerToUse,
boolean releaseSchedulerOnClose,
PushStream<T> stream) |
|
<R> PushStream<R> |
AbstractPushStreamImpl.coalesce(int count,
Function<java.util.Collection<T>,R> f) |
|
<R> PushStream<R> |
AbstractPushStreamImpl.coalesce(java.util.function.IntSupplier count,
Function<java.util.Collection<T>,R> f) |
|
<R> PushStream<R> |
AbstractPushStreamImpl.coalesce(Function<? super T,java.util.Optional<R>> accumulator) |
|
<R> PushStream<R> |
PushStream.coalesce(int count,
Function<java.util.Collection<T>,R> f) |
Coalesces a number of events into a new type of event.
|
<R> PushStream<R> |
PushStream.coalesce(java.util.function.IntSupplier count,
Function<java.util.Collection<T>,R> f) |
Coalesces a number of events into a new type of event.
|
<R> PushStream<R> |
PushStream.coalesce(Function<? super T,java.util.Optional<R>> f) |
Coalesces a number of events into a new type of event.
|
<T> PushStream<T> |
PushStreamProvider.createStream(PushEventSource<T> eventSource) |
Create a stream with the default configured buffer, executor size, queue,
queue policy and pushback policy.
|
(package private) <T,U extends java.util.concurrent.BlockingQueue<PushEvent<? extends T>>> PushStream<T> |
PushStreamProvider.createStream(PushEventSource<T> eventSource,
int parallelism,
java.util.concurrent.Executor executor,
java.util.concurrent.ScheduledExecutorService scheduler,
U queue,
QueuePolicy<T,U> queuePolicy,
PushbackPolicy<T,U> pushbackPolicy) |
|
(package private) <T> PushStream<T> |
PushStreamProvider.createUnbufferedStream(PushEventSource<T> eventSource,
java.util.concurrent.Executor executor,
java.util.concurrent.ScheduledExecutorService scheduler) |
|
PushStream<T> |
AbstractPushStreamImpl.distinct() |
|
PushStream<T> |
PushStream.distinct() |
Remove any duplicates.
|
PushStream<T> |
AbstractPushStreamImpl.filter(Predicate<? super T> predicate) |
|
PushStream<T> |
PushStream.filter(Predicate<? super T> predicate) |
Only pass events downstream when the predicate tests true.
|
<R> PushStream<R> |
AbstractPushStreamImpl.flatMap(Function<? super T,? extends PushStream<? extends R>> mapper) |
|
<R> PushStream<R> |
PushStream.flatMap(Function<? super T,? extends PushStream<? extends R>> mapper) |
Flat map the payload value (turn one event into 0..n events of
potentially another type).
|
PushStream<T> |
AbstractPushStreamImpl.fork(int n,
int delay,
java.util.concurrent.Executor ex) |
|
PushStream<T> |
PushStream.fork(int n,
int delay,
java.util.concurrent.Executor e) |
Execute the downstream events in up to n background threads.
|
PushStream<T> |
AbstractPushStreamImpl.limit(long maxSize) |
|
PushStream<T> |
AbstractPushStreamImpl.limit(java.time.Duration maxTime) |
|
PushStream<T> |
PushStream.limit(long maxSize) |
Automatically close the channel after the maxSize number of elements is
received.
|
PushStream<T> |
PushStream.limit(java.time.Duration maxTime) |
Automatically close the channel after the given amount of time has
elapsed.
|
<R> PushStream<R> |
AbstractPushStreamImpl.map(Function<? super T,? extends R> mapper) |
|
<R> PushStream<R> |
PushStream.map(Function<? super T,? extends R> mapper) |
Map a payload value.
|
PushStream<T> |
AbstractPushStreamImpl.merge(PushEventSource<? extends T> source) |
|
PushStream<T> |
AbstractPushStreamImpl.merge(PushStream<? extends T> source) |
|
PushStream<T> |
PushStream.merge(PushEventSource<? extends T> source) |
Merge in the events from another source.
|
PushStream<T> |
PushStream.merge(PushStream<? extends T> source) |
Merge in the events from another PushStream.
|
PushStream<T> |
AbstractPushStreamImpl.onClose(java.lang.Runnable closeHandler) |
|
PushStream<T> |
PushStream.onClose(java.lang.Runnable closeHandler) |
Must be run after the channel is closed.
|
PushStream<T> |
AbstractPushStreamImpl.onError(java.util.function.Consumer<? super java.lang.Throwable> closeHandler) |
|
PushStream<T> |
PushStream.onError(java.util.function.Consumer<? super java.lang.Throwable> closeHandler) |
Must be run after the channel is closed.
|
PushStream<T> |
AbstractPushStreamImpl.sequential() |
|
PushStream<T> |
PushStream.sequential() |
Ensure that any events are delivered sequentially.
|
PushStream<T> |
AbstractPushStreamImpl.skip(long n) |
|
PushStream<T> |
PushStream.skip(long n) |
Skip a number of events in the channel.
|
PushStream<T> |
AbstractPushStreamImpl.sorted() |
|
PushStream<T> |
AbstractPushStreamImpl.sorted(java.util.Comparator<? super T> comparator) |
|
PushStream<T> |
PushStream.sorted() |
Sorted the elements, assuming that T extends Comparable.
|
PushStream<T> |
PushStream.sorted(java.util.Comparator<? super T> comparator) |
Sorted the elements with the given comparator.
|
PushStream<T>[] |
AbstractPushStreamImpl.split(Predicate<? super T>... predicates) |
|
PushStream<T>[] |
PushStream.split(Predicate<? super T>... predicates) |
Split the events to different streams based on a predicate.
|
<T> PushStream<T> |
PushStreamProvider.streamOf(java.util.concurrent.Executor executor,
java.util.concurrent.ScheduledExecutorService scheduler,
java.util.stream.Stream<T> items) |
Create an Unbuffered PushStream from a Java Stream The
data from the stream will be pushed into the PushStream asynchronously
using the supplied Executor.
|
<T> PushStream<T> |
PushStreamProvider.streamOf(java.util.stream.Stream<T> items) |
Create an Unbuffered PushStream from a Java Stream The
data from the stream will be pushed into the PushStream synchronously as
it is opened.
|
PushStream<T> |
AbstractPushStreamImpl.timeout(java.time.Duration maxTime) |
|
PushStream<T> |
PushStream.timeout(java.time.Duration idleTime) |
Automatically fail the channel if no events are received for the
indicated length of time.
|
<R> PushStream<R> |
AbstractPushStreamImpl.window(java.time.Duration time,
java.util.concurrent.Executor executor,
Function<java.util.Collection<T>,R> f) |
|
<R> PushStream<R> |
AbstractPushStreamImpl.window(java.time.Duration time,
Function<java.util.Collection<T>,R> f) |
|
<R> PushStream<R> |
AbstractPushStreamImpl.window(java.util.function.Supplier<java.time.Duration> time,
java.util.function.IntSupplier maxEvents,
java.util.concurrent.Executor ex,
java.util.function.BiFunction<java.lang.Long,java.util.Collection<T>,R> f) |
|
<R> PushStream<R> |
AbstractPushStreamImpl.window(java.util.function.Supplier<java.time.Duration> time,
java.util.function.IntSupplier maxEvents,
java.util.function.BiFunction<java.lang.Long,java.util.Collection<T>,R> f) |
|
<R> PushStream<R> |
PushStream.window(java.time.Duration d,
java.util.concurrent.Executor executor,
Function<java.util.Collection<T>,R> f) |
Buffers a number of events over a fixed time interval and then forwards
the events to an accumulator function.
|
<R> PushStream<R> |
PushStream.window(java.time.Duration d,
Function<java.util.Collection<T>,R> f) |
Buffers a number of events over a fixed time interval and then forwards
the events to an accumulator function.
|
<R> PushStream<R> |
PushStream.window(java.util.function.Supplier<java.time.Duration> timeSupplier,
java.util.function.IntSupplier maxEvents,
java.util.concurrent.Executor executor,
java.util.function.BiFunction<java.lang.Long,java.util.Collection<T>,R> f) |
Buffers a number of events over a variable time interval and then
forwards the events to an accumulator function.
|
<R> PushStream<R> |
PushStream.window(java.util.function.Supplier<java.time.Duration> timeSupplier,
java.util.function.IntSupplier maxEvents,
java.util.function.BiFunction<java.lang.Long,java.util.Collection<T>,R> f) |
Buffers a number of events over a variable time interval and then
forwards the events to an accumulator function.
|