class IntermediatePushStreamImpl<T> extends AbstractPushStreamImpl<T> implements PushStream<T>
AbstractPushStreamImpl.State
Modifier and Type | Field and Description |
---|---|
private AbstractPushStreamImpl<?> |
previous |
closed, next, onCloseCallback, onErrorCallback, promiseFactory, psp
Constructor and Description |
---|
IntermediatePushStreamImpl(PushStreamProvider psp,
PromiseFactory promiseFactory,
AbstractPushStreamImpl<?> previous) |
Modifier and Type | Method and Description |
---|---|
protected boolean |
begin() |
protected void |
beginning() |
protected void |
upstreamClose(PushEvent<?> close) |
adjustBackPressure, adjustBackPressure, allMatch, anyMatch, asyncMap, buffer, buildBuffer, check, close, 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
private final AbstractPushStreamImpl<?> previous
IntermediatePushStreamImpl(PushStreamProvider psp, PromiseFactory promiseFactory, AbstractPushStreamImpl<?> previous)
protected boolean begin()
begin
in class AbstractPushStreamImpl<T>
protected void beginning()
protected void upstreamClose(PushEvent<?> close)
upstreamClose
in class AbstractPushStreamImpl<T>