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