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, windowclone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitadjustBackPressure, 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, windowprivate 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>