Package org.osgi.util.pushstream
Class UnbufferedPushStreamImpl<T,U extends BlockingQueue<PushEvent<? extends T>>>
java.lang.Object
org.osgi.util.pushstream.AbstractPushStreamImpl<T>
org.osgi.util.pushstream.UnbufferedPushStreamImpl<T,U>
- All Implemented Interfaces:
AutoCloseable
,PushStream<T>
- Direct Known Subclasses:
BufferedPushStreamImpl
class UnbufferedPushStreamImpl<T,U extends BlockingQueue<PushEvent<? extends 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
FieldsModifier and TypeFieldDescriptionprotected final Function
<PushEventConsumer<T>, AutoCloseable> protected final AtomicReference
<AutoCloseable> Fields inherited from class org.osgi.util.pushstream.AbstractPushStreamImpl
closed, next, onCloseCallback, onErrorCallback, promiseFactory, psp
-
Constructor Summary
ConstructorsConstructorDescriptionUnbufferedPushStreamImpl
(PushStreamProvider psp, PromiseFactory promiseFactory, Function<PushEventConsumer<T>, AutoCloseable> connector) -
Method Summary
Methods inherited from class org.osgi.util.pushstream.AbstractPushStreamImpl
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
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
-
connector
-
upstream
-
-
Constructor Details
-
UnbufferedPushStreamImpl
UnbufferedPushStreamImpl(PushStreamProvider psp, PromiseFactory promiseFactory, Function<PushEventConsumer<T>, AutoCloseable> connector)
-
-
Method Details
-
close
- Overrides:
close
in classAbstractPushStreamImpl<T>
-
upstreamClose
- Specified by:
upstreamClose
in classAbstractPushStreamImpl<T>
-
begin
protected boolean begin()- Specified by:
begin
in classAbstractPushStreamImpl<T>
-