Package org.osgi.util.pushstream

Class IntermediatePushStreamImpl<T>

java.lang.Object

org.osgi.util.pushstream.AbstractPushStreamImpl<T>

org.osgi.util.pushstream.IntermediatePushStreamImpl<T>

All Implemented Interfaces:

AutoCloseable, PushStream<T>

class IntermediatePushStreamImpl<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	Description
private final AbstractPushStreamImpl<?>	previous

Fields inherited from class org.osgi.util.pushstream.AbstractPushStreamImpl

closed, next, onCloseCallback, onErrorCallback, promiseFactory, psp

Constructor Summary

Constructors

Constructor	Description
IntermediatePushStreamImpl(PushStreamProvider psp, PromiseFactory promiseFactory, AbstractPushStreamImpl<?> previous)

Method Summary

Modifier and Type	Method	Description
protected boolean	begin()
protected void	beginning()
protected void	upstreamClose(PushEvent<?> close)

Methods inherited from class org.osgi.util.pushstream.AbstractPushStreamImpl

adjustBackPressure, adjustBackPressure, allMatch, anyMatch, asyncMap, buffer, buildBuffer, check, close, 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 Details

previous

private final AbstractPushStreamImpl<?> previous

Constructor Details

IntermediatePushStreamImpl

IntermediatePushStreamImpl(PushStreamProvider psp,
 PromiseFactory promiseFactory,
 AbstractPushStreamImpl<?> previous)

Method Details

begin

protected boolean begin()

Specified by:

begin in class AbstractPushStreamImpl<T>

beginning

protected void beginning()

upstreamClose

protected void upstreamClose(PushEvent<?> close)

Specified by:

upstreamClose in class AbstractPushStreamImpl<T>