Top Fields Constructors Methods

org.osgi.util.pushstream

pack-priv Class BufferedPushStreamImpl<T, U extends BlockingQueue<PushEvent<? extends T>>>

Class Inheritance

extends UnbufferedPushStreamImpl<T, U extends BlockingQueue<PushEvent<? extends T>>>
implements PushStream<T>

java.lang.Object
org.osgi.util.pushstream.AbstractPushStreamImpl
org.osgi.util.pushstream.UnbufferedPushStreamImpl
org.osgi.util.pushstream.BufferedPushStreamImpl

All Implemented Interfaces

org.osgi.util.pushstream.PushStream, java.lang.AutoCloseable

Static Imports

java.util.concurrent.TimeUnit.MILLISECONDS, org.osgi.util.pushstream.AbstractPushStreamImpl.State.CLOSED, .PushEventConsumer.ABORT

Field Summary

Modifier and Type	Field and Description
private final U	eventQueue
private final int	parallelism
private final PushbackPolicy<T, U>	pushbackPolicy
private final QueuePolicy<T, U>	queuePolicy
private final Semaphore	semaphore
private final AtomicBoolean	softClose Indicates that a terminal event has been received, that we should stop collecting new events, and that we must drain the buffer before continuing

Inherited from org.osgi.util.pushstream.UnbufferedPushStreamImpl:: connector upstream

Constructor Summary

Access	Constructor and Description
pack-priv	BufferedPushStreamImpl(PushStreamProvider psp, PromiseFactory promiseFactory, U eventQueue, int parallelism, QueuePolicy<T, U> queuePolicy, PushbackPolicy<T, U> pushbackPolicy, Function<PushEventConsumer<T>, AutoCloseable> connector)

Method Summary

Modifier and Type	Method and Description
protected long	handleEvent(PushEvent<? extends T> event) Overrides org.osgi.util.pushstream.AbstractPushStreamImpl.handleEvent.
private void	startWorker()

Inherited from org.osgi.util.pushstream.UnbufferedPushStreamImpl:: begin close upstreamClose

Field Detail

eventQueue	back to summary
private final U eventQueue

parallelism	back to summary
private final int parallelism

pushbackPolicy	back to summary
private final PushbackPolicy<T, U> pushbackPolicy

queuePolicy	back to summary
private final QueuePolicy<T, U> queuePolicy

semaphore	back to summary
private final Semaphore semaphore

softClose	back to summary
private final AtomicBoolean softClose Indicates that a terminal event has been received, that we should stop collecting new events, and that we must drain the buffer before continuing

Constructor Detail

BufferedPushStreamImpl	back to summary
pack-priv BufferedPushStreamImpl(PushStreamProvider psp, PromiseFactory promiseFactory, U eventQueue, int parallelism, QueuePolicy<T, U> queuePolicy, PushbackPolicy<T, U> pushbackPolicy, Function<PushEventConsumer<T>, AutoCloseable> connector)

Method Detail

handleEvent

back to summary

protected long handleEvent(PushEvent<? extends T> event)

Overrides org.osgi.util.pushstream.AbstractPushStreamImpl.handleEvent.

Annotations

@Override

startWorker	back to summary
private void startWorker()