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:
java.lang.AutoCloseable
,PushStream<T>
class IntermediatePushStreamImpl<T> extends AbstractPushStreamImpl<T> implements PushStream<T>
-
-
Nested Class Summary
-
Nested classes/interfaces inherited from class org.osgi.util.pushstream.AbstractPushStreamImpl
AbstractPushStreamImpl.State
-
-
Field Summary
Fields Modifier and Type Field Description private AbstractPushStreamImpl<?>
previous
-
Fields inherited from class org.osgi.util.pushstream.AbstractPushStreamImpl
closed, next, onCloseCallback, onErrorCallback, promiseFactory, psp
-
-
Constructor Summary
Constructors Constructor Description IntermediatePushStreamImpl(PushStreamProvider psp, PromiseFactory promiseFactory, AbstractPushStreamImpl<?> previous)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description protected boolean
begin()
protected void
beginning()
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 Detail
-
previous
private final AbstractPushStreamImpl<?> previous
-
-
Constructor Detail
-
IntermediatePushStreamImpl
IntermediatePushStreamImpl(PushStreamProvider psp, PromiseFactory promiseFactory, AbstractPushStreamImpl<?> previous)
-
-
Method Detail
-
begin
protected boolean begin()
- Specified by:
begin
in classAbstractPushStreamImpl<T>
-
beginning
protected void beginning()
-
upstreamClose
protected void upstreamClose(PushEvent<?> close)
- Specified by:
upstreamClose
in classAbstractPushStreamImpl<T>
-
-