Uses of Class
org.osgi.util.pushstream.PushEvent

Packages that use PushEvent

Package	Description
org.osgi.util.pushstream	Push Stream Package Version 1.0.

Uses of PushEvent in org.osgi.util.pushstream

Classes in org.osgi.util.pushstream with type parameters of type PushEvent

Modifier and Type	Class	Description
(package private) class	AbstractBufferBuilder<R,T,U extends BlockingQueue<PushEvent<? extends T>>>
interface	BufferBuilder<R,T,U extends BlockingQueue<PushEvent<? extends T>>>	Create a buffered section of a Push-based stream
(package private) class	BufferedPushStreamImpl<T,U extends BlockingQueue<PushEvent<? extends T>>>
interface	PushbackPolicy<T,U extends BlockingQueue<PushEvent<? extends T>>>	A PushbackPolicy is used to calculate how much back pressure to apply based on the current buffer.
interface	PushStreamBuilder<T,U extends BlockingQueue<PushEvent<? extends T>>>	A Builder for a PushStream.
(package private) class	PushStreamBuilderImpl<T,U extends BlockingQueue<PushEvent<? extends T>>>
interface	QueuePolicy<T,U extends BlockingQueue<PushEvent<? extends T>>>	A QueuePolicy is used to control how events should be queued in the current buffer.
(package private) class	SimplePushEventSourceImpl<T,U extends BlockingQueue<PushEvent<? extends T>>>
(package private) class	UnbufferedPushStreamImpl<T,U extends BlockingQueue<PushEvent<? extends T>>>

Subclasses of PushEvent in org.osgi.util.pushstream

Modifier and Type	Class	Description
(package private) static final class	PushEvent.CloseEvent<T>
(package private) static final class	PushEvent.DataEvent<T>
(package private) static final class	PushEvent.ErrorEvent<T>

Fields in org.osgi.util.pushstream with type parameters of type PushEvent

Modifier and Type	Field	Description
private final AtomicReference<PushEvent<T>>	PushStreamProvider.MultiplexingConsumer.terminalEventStore

Methods in org.osgi.util.pushstream with type parameters of type PushEvent

Modifier and Type	Method	Description
<U extends BlockingQueue<PushEvent<? extends T>>> PushStreamBuilder<T,U>	AbstractPushStreamImpl.buildBuffer()
<U extends BlockingQueue<PushEvent<? extends T>>> PushStreamBuilder<T,U>	PushStream.buildBuffer()	Build a buffer to enqueue events in a queue using custom values for the queue size and other behaviors.
<T, U extends BlockingQueue<PushEvent<? extends T>>> BufferBuilder<PushEventConsumer<T>,T,U>	PushStreamProvider.buildBufferedConsumer(PushEventConsumer<T> delegate)	Build a buffered PushEventConsumer with custom configuration.
<T, U extends BlockingQueue<PushEvent<? extends T>>> BufferBuilder<PushEventSource<T>,T,U>	PushStreamProvider.buildEventSourceFromStream(PushStream<T> stream)	Convert an PushStream into an PushEventSource.
<T, U extends BlockingQueue<PushEvent<? extends T>>> BufferBuilder<SimplePushEventSource<T>,T,U>	PushStreamProvider.buildSimpleEventSource(Class<T> type)	Build a SimplePushEventSource with the supplied type and custom buffering behaviors.
<T, U extends BlockingQueue<PushEvent<? extends T>>> PushStreamBuilder<T,U>	PushStreamProvider.buildStream(PushEventSource<T> eventSource)	Builds a push stream with custom configuration.
(package private) <T, U extends BlockingQueue<PushEvent<? extends T>>> SimplePushEventSource<T>	PushStreamProvider.createSimplePushEventSource(int parallelism, Executor executor, U queue, QueuePolicy<T,U> queuePolicy, Runnable onClose)
(package private) <T, U extends BlockingQueue<PushEvent<? extends T>>> PushStream<T>	PushStreamProvider.createStream(PushEventSource<T> eventSource, int parallelism, Executor executor, ScheduledExecutorService scheduler, U queue, QueuePolicy<T,U> queuePolicy, PushbackPolicy<T,U> pushbackPolicy)
abstract <T, U extends BlockingQueue<PushEvent<? extends T>>> PushbackPolicy<T,U>	PushbackPolicyOption.getPolicy(long value)	Create a PushbackPolicy instance configured with a base back pressure time in nanoseconds The actual backpressure returned will vary based on the selected implementation, the base value, and the state of the buffer.
abstract <T, U extends BlockingQueue<PushEvent<? extends T>>> QueuePolicy<T,U>	QueuePolicyOption.getPolicy()

Methods in org.osgi.util.pushstream that return PushEvent

Modifier and Type	Method	Description
static <T> PushEvent<T>	PushEvent.close()	Create a new close event.
static <T> PushEvent<T>	PushEvent.data(T payload)	Create a new data event.
static <T> PushEvent<T>	PushEvent.error(Throwable t)	Create a new error event.
<X> PushEvent<X>	PushEvent.DataEvent.nodata()
<X> PushEvent<X>	PushEvent.nodata()	Convenience to cast a close/error event to another payload type.

Methods in org.osgi.util.pushstream with parameters of type PushEvent

Modifier and Type	Method	Description
long	PushEventConsumer.accept(PushEvent<? extends T> event)	Accept an event from a source.
long	PushStreamProvider.MultiplexingConsumer.accept(PushEvent<? extends T> event)
long	PushStreamProvider.PushEventPipe.accept(PushEvent<? extends T> event)
private <R> void	AbstractPushStreamImpl.aggregateAndForward(BiFunction<Long,Collection<T>,R> f, AbstractPushStreamImpl<R> eventStream, PushEvent<? extends T> event, Queue<T> queue, Executor executor, long elapsed)
private <R> long	AbstractPushStreamImpl.aggregateAndForward(Function<Collection<T>,R> f, AbstractPushStreamImpl<R> eventStream, PushEvent<? extends T> event, Queue<T> queue)
protected boolean	AbstractPushStreamImpl.close(PushEvent<T> event)
protected boolean	AbstractPushStreamImpl.close(PushEvent<T> event, boolean sendDownStreamEvent)
private void	SimplePushEventSourceImpl.close(PushEvent<T> event)
protected boolean	UnbufferedPushStreamImpl.close(PushEvent<T> event, boolean sendDownStreamEvent)
private void	SimplePushEventSourceImpl.closeConsumer(PushEventConsumer<? super T> pec, PushEvent<T> event)
private Promise<Long>	SimplePushEventSourceImpl.deliver(List<PushEventConsumer<? super T>> toCall, PushEvent<T> event)
private Promise<Long>	SimplePushEventSourceImpl.doCall(PushEvent<T> event, PushEventConsumer<? super T> pec)
void	QueuePolicy.doOffer(U queue, PushEvent<? extends T> event)	Enqueue the event and return the remaining capacity available for events
private void	SimplePushEventSourceImpl.doSend(PushEventConsumer<? super T> pec, PushEvent<T> event)
private Promise<Long>	SimplePushEventSourceImpl.doSendWithBackPressure(PushEventConsumer<? super T> pec, PushEvent<T> event)
private void	SimplePushEventSourceImpl.enqueueEvent(PushEvent<T> event)
protected long	AbstractPushStreamImpl.handleEvent(PushEvent<? extends T> event)
protected long	BufferedPushStreamImpl.handleEvent(PushEvent<? extends T> event)
private long	SimplePushEventSourceImpl.safePush(PushEventConsumer<? super T> pec, PushEvent<T> event)
protected abstract void	AbstractPushStreamImpl.upstreamClose(PushEvent<?> close)
protected void	IntermediatePushStreamImpl.upstreamClose(PushEvent<?> close)
protected void	UnbufferedPushStreamImpl.upstreamClose(PushEvent<?> close)

Constructor parameters in org.osgi.util.pushstream with type arguments of type PushEvent

Modifier	Constructor	Description
	MultiplexingConsumer(AtomicReference<PushEvent<T>> terminalEventStore, CopyOnWriteArrayList<PushEventConsumer<? super T>> consumers)