Top Fields Constructors Methods
org.osgi.util.pushstream

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

extends AbstractPushStreamImpl<T>
implements PushStream<T>
Class Inheritance
All Implemented Interfaces
org.osgi.util.pushstream.PushStream, java.lang.AutoCloseable
Known Direct Subclasses
org.osgi.util.pushstream.BufferedPushStreamImpl
Static Imports
java.util.Optional.ofNullable, org.osgi.util.pushstream.AbstractPushStreamImpl.State.BUILDING, .AbstractPushStreamImpl.State.CLOSED, .AbstractPushStreamImpl.State.STARTED

Field Summary

Modifier and TypeField and Description
protected final Function<PushEventConsumer<T>, AutoCloseable>
connector

protected final AtomicReference<AutoCloseable>
upstream

Inherited from org.osgi.util.pushstream.AbstractPushStreamImpl:
closednextonCloseCallbackonErrorCallbackpromiseFactorypsp

Constructor Summary

AccessConstructor and Description
pack-priv
UnbufferedPushStreamImpl(PushStreamProvider psp, PromiseFactory promiseFactory, Function<PushEventConsumer<T>, AutoCloseable> connector)

Method Summary

Modifier and TypeMethod and Description
protected boolean
begin()

Implements abstract org.osgi.util.pushstream.AbstractPushStreamImpl.begin.

protected boolean
close(PushEvent<T> event, boolean sendDownStreamEvent)

Overrides org.osgi.util.pushstream.AbstractPushStreamImpl.close.

protected void
upstreamClose(PushEvent<?> close)

Implements abstract org.osgi.util.pushstream.AbstractPushStreamImpl.upstreamClose.

Inherited from org.osgi.util.pushstream.AbstractPushStreamImpl:
adjustBackPressureadjustBackPressureallMatchanyMatchasyncMapbufferbuildBuffercheckcloseclosecoalescecoalescecoalescecollectcountdistinctfilterfindAnyfindFirstflatMapforEachforEachEventforkgetQueueForInternalBufferinghandleEventlimitlimitmapmaxmergemergeminnoneMatchonCloseonErrorreducereducereducesequentialskipsortedsortedsplittimeouttoArraytoArraywindowwindowwindowwindow

Field Detail

connectorback to summary
protected final Function<PushEventConsumer<T>, AutoCloseable> connector
upstreamback to summary
protected final AtomicReference<AutoCloseable> upstream

Constructor Detail

UnbufferedPushStreamImplback to summary
pack-priv UnbufferedPushStreamImpl(PushStreamProvider psp, PromiseFactory promiseFactory, Function<PushEventConsumer<T>, AutoCloseable> connector)

Method Detail

beginback to summary
protected boolean begin()

Implements abstract org.osgi.util.pushstream.AbstractPushStreamImpl.begin.

Annotations
@Override
closeback to summary
protected boolean close(PushEvent<T> event, boolean sendDownStreamEvent)

Overrides org.osgi.util.pushstream.AbstractPushStreamImpl.close.

Annotations
@Override
upstreamCloseback to summary
protected void upstreamClose(PushEvent<?> close)

Implements abstract org.osgi.util.pushstream.AbstractPushStreamImpl.upstreamClose.

Annotations
@Override