Package org.osgi.util.pushstream
Class IntermediatePushStreamImpl<T>
java.lang.Object
org.osgi.util.pushstream.AbstractPushStreamImpl<T>
org.osgi.util.pushstream.IntermediatePushStreamImpl<T>
- All Implemented Interfaces:
AutoCloseable
,PushStream<T>
-
Nested Class Summary
Nested classes/interfaces inherited from class org.osgi.util.pushstream.AbstractPushStreamImpl
AbstractPushStreamImpl.State
-
Field Summary
FieldsFields inherited from class org.osgi.util.pushstream.AbstractPushStreamImpl
closed, next, onCloseCallback, onErrorCallback, promiseFactory, psp
-
Constructor Summary
ConstructorsConstructorDescriptionIntermediatePushStreamImpl
(PushStreamProvider psp, PromiseFactory promiseFactory, AbstractPushStreamImpl<?> previous) -
Method Summary
Modifier and TypeMethodDescriptionprotected boolean
begin()
protected void
protected void
upstreamClose
(PushEvent<?> close) Methods inherited from class org.osgi.util.pushstream.AbstractPushStreamImpl
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
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
Methods inherited from interface org.osgi.util.pushstream.PushStream
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
-
Field Details
-
previous
-
-
Constructor Details
-
IntermediatePushStreamImpl
IntermediatePushStreamImpl(PushStreamProvider psp, PromiseFactory promiseFactory, AbstractPushStreamImpl<?> previous)
-
-
Method Details
-
begin
protected boolean begin()- Specified by:
begin
in classAbstractPushStreamImpl<T>
-
beginning
protected void beginning() -
upstreamClose
- Specified by:
upstreamClose
in classAbstractPushStreamImpl<T>
-