class UnbufferedPushStreamImpl<T,U extends java.util.concurrent.BlockingQueue<PushEvent<? extends T>>> extends AbstractPushStreamImpl<T> implements PushStream<T>
AbstractPushStreamImpl.State
Modifier and Type | Field and Description |
---|---|
protected java.util.function.Function<PushEventConsumer<T>,java.lang.AutoCloseable> |
connector |
protected java.util.concurrent.atomic.AtomicReference<java.lang.AutoCloseable> |
upstream |
closed, next, onCloseCallback, onErrorCallback, promiseFactory, psp
Constructor and Description |
---|
UnbufferedPushStreamImpl(PushStreamProvider psp,
PromiseFactory promiseFactory,
java.util.function.Function<PushEventConsumer<T>,java.lang.AutoCloseable> connector) |
Modifier and Type | Method and Description |
---|---|
protected boolean |
begin() |
protected boolean |
close(PushEvent<T> event,
boolean sendDownStreamEvent) |
protected void |
upstreamClose(PushEvent<?> close) |
adjustBackPressure, adjustBackPressure, allMatch, anyMatch, asyncMap, buffer, buildBuffer, check, close, close, coalesce, coalesce, coalesce, collect, count, distinct, filter, findAny, findFirst, flatMap, forEach, forEachEvent, fork, getQueueForInternalBuffering, handleEvent, limit, limit, map, max, merge, merge, min, noneMatch, onClose, onError, reduce, reduce, reduce, sequential, skip, sorted, sorted, split, timeout, toArray, toArray, window, window, window, window
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
adjustBackPressure, adjustBackPressure, allMatch, anyMatch, asyncMap, buffer, buildBuffer, close, coalesce, coalesce, coalesce, collect, count, distinct, filter, findAny, findFirst, flatMap, forEach, forEachEvent, fork, limit, limit, map, max, merge, merge, min, noneMatch, onClose, onError, reduce, reduce, reduce, sequential, skip, sorted, sorted, split, timeout, toArray, toArray, window, window, window, window
protected final java.util.function.Function<PushEventConsumer<T>,java.lang.AutoCloseable> connector
protected final java.util.concurrent.atomic.AtomicReference<java.lang.AutoCloseable> upstream
UnbufferedPushStreamImpl(PushStreamProvider psp, PromiseFactory promiseFactory, java.util.function.Function<PushEventConsumer<T>,java.lang.AutoCloseable> connector)
protected boolean close(PushEvent<T> event, boolean sendDownStreamEvent)
close
in class AbstractPushStreamImpl<T>
protected void upstreamClose(PushEvent<?> close)
upstreamClose
in class AbstractPushStreamImpl<T>
protected boolean begin()
begin
in class AbstractPushStreamImpl<T>