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 and 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 and Description
UnbufferedPushStreamImpl(PushStreamProvider psp, PromiseFactory promiseFactory, java.util.function.Function<PushEventConsumer<T>,java.lang.AutoCloseable> connector)

Method Summary

Modifier and Type	Method and 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 class AbstractPushStreamImpl<T>

upstreamClose

protected void upstreamClose(PushEvent<?> close)

Specified by:

upstreamClose in class AbstractPushStreamImpl<T>

begin

protected boolean begin()

Specified by:

begin in class AbstractPushStreamImpl<T>