Top Fields Constructors Methods
org.osgi.util.pushstream

pack-priv Class IntermediatePushStreamImpl<T>

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

Field Summary

Modifier and TypeField and Description
private final AbstractPushStreamImpl<?>
Inherited from org.osgi.util.pushstream.AbstractPushStreamImpl:
closednextonCloseCallbackonErrorCallbackpromiseFactorypsp

Constructor Summary

AccessConstructor and Description
pack-priv

Method Summary

Modifier and TypeMethod and Description
protected boolean
protected void
protected void
Inherited from org.osgi.util.pushstream.AbstractPushStreamImpl:
adjustBackPressureadjustBackPressureallMatchanyMatchasyncMapbufferbuildBuffercheckclosecloseclosecoalescecoalescecoalescecollectcountdistinctfilterfindAnyfindFirstflatMapforEachforEachEventforkgetQueueForInternalBufferinghandleEventlimitlimitmapmaxmergemergeminnoneMatchonCloseonErrorreducereducereducesequentialskipsortedsortedsplittimeouttoArraytoArraywindowwindowwindowwindow

Field Detail

previousback to summary
private final AbstractPushStreamImpl<?> previous

Constructor Detail

IntermediatePushStreamImplback to summary
pack-priv IntermediatePushStreamImpl(PushStreamProvider psp, PromiseFactory promiseFactory, AbstractPushStreamImpl<?> previous)

Method Detail

beginback to summary
protected boolean begin()

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

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

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

Annotations
@Override