AbstractPushStreamImpl(PushStreamProvider psp,
PromiseFactory promiseFactory) |
BufferedPushStreamImpl(PushStreamProvider psp,
PromiseFactory promiseFactory,
U eventQueue,
int parallelism,
QueuePolicy<T,U> queuePolicy,
PushbackPolicy<T,U> pushbackPolicy,
java.util.function.Function<PushEventConsumer<T>,java.lang.AutoCloseable> connector) |
IntermediatePushStreamImpl(PushStreamProvider psp,
PromiseFactory promiseFactory,
AbstractPushStreamImpl<?> previous) |
PushStreamBuilderImpl(PushStreamProvider psp,
java.util.concurrent.Executor defaultExecutor,
java.util.concurrent.ScheduledExecutorService defaultScheduler,
PushEventSource<T> eventSource) |
UnbufferedPushStreamImpl(PushStreamProvider psp,
PromiseFactory promiseFactory,
java.util.function.Function<PushEventConsumer<T>,java.lang.AutoCloseable> connector) |