Package akka.stream.impl
Class FanoutOutputs
- java.lang.Object
-
- akka.stream.impl.FanoutOutputs
-
- All Implemented Interfaces:
DefaultOutputTransferStates
,Outputs
,ResizableMultiReaderRingBuffer.Cursors
,SubscriberManagement<java.lang.Object>
public abstract class FanoutOutputs extends java.lang.Object implements DefaultOutputTransferStates, SubscriberManagement<java.lang.Object>
INTERNAL API
-
-
Nested Class Summary
-
Nested classes/interfaces inherited from interface akka.stream.impl.SubscriberManagement
SubscriberManagement.Completed$, SubscriberManagement.EndOfStream, SubscriberManagement.ErrorCompleted, SubscriberManagement.ErrorCompleted$, SubscriberManagement.NotReached$
-
-
Constructor Summary
Constructors Constructor Description FanoutOutputs(int maxBufferSize, int initialBufferSize, ActorRef self, Pump pump)
-
Method Summary
All Methods Instance Methods Abstract Methods Concrete Methods Modifier and Type Method Description abstract void
afterShutdown()
protected void
akka$stream$impl$DefaultOutputTransferStates$_setter_$NeedsDemand_$eq(TransferState x$1)
void
cancel()
protected void
cancelUpstream()
called beforeshutdown()
if the stream is *not* being regularly completed but shut-down due to the last subscriber having canceled its subscriptionvoid
complete()
ActorSubscriptionWithCursor<? super java.lang.Object>
createSubscription(org.reactivestreams.Subscriber<? super java.lang.Object> subscriber)
Use to register a subscriberboolean
demandAvailable()
long
demandCount()
protected scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit>
downstreamRunning()
void
enqueueOutputElement(java.lang.Object elem)
void
error(java.lang.Throwable e)
protected ActorPublisher<java.lang.Object>
exposedPublisher()
protected void
exposedPublisher_$eq(ActorPublisher<java.lang.Object> x$1)
int
initialBufferSize()
boolean
isClosed()
int
maxBufferSize()
TransferState
NeedsDemand()
Pump
pump()
protected void
requestFromUpstream(long elements)
called when we are ready to consume more elements from our upstream MUST NOT call pushToDownstreamprotected void
shutdown(boolean completed)
called when the spi.Publisher/Processor is ready to be shut downSubReceive
subreceive()
protected scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit>
waitingExposedPublisher()
-
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
-
Methods inherited from interface akka.stream.impl.DefaultOutputTransferStates
NeedsDemandOrCancel
-
Methods inherited from interface akka.stream.impl.SubscriberManagement
abortDownstream, addSubscription, bufferDebug, completeDownstream, cursors, endOfStream_$eq, moreRequested, pendingFromUpstream_$eq, pushToDownstream, registerSubscriber, requestFromUpstreamIfRequired, subscriptions_$eq, unregisterSubscription, unregisterSubscriptionInternal
-
-
-
-
Method Detail
-
NeedsDemand
public TransferState NeedsDemand()
- Specified by:
NeedsDemand
in interfaceDefaultOutputTransferStates
- Specified by:
NeedsDemand
in interfaceOutputs
-
afterShutdown
public abstract void afterShutdown()
-
akka$stream$impl$DefaultOutputTransferStates$_setter_$NeedsDemand_$eq
protected void akka$stream$impl$DefaultOutputTransferStates$_setter_$NeedsDemand_$eq(TransferState x$1)
- Specified by:
akka$stream$impl$DefaultOutputTransferStates$_setter_$NeedsDemand_$eq
in interfaceDefaultOutputTransferStates
-
cancelUpstream
protected void cancelUpstream()
Description copied from interface:SubscriberManagement
called beforeshutdown()
if the stream is *not* being regularly completed but shut-down due to the last subscriber having canceled its subscription- Specified by:
cancelUpstream
in interfaceSubscriberManagement<java.lang.Object>
-
createSubscription
public ActorSubscriptionWithCursor<? super java.lang.Object> createSubscription(org.reactivestreams.Subscriber<? super java.lang.Object> subscriber)
Description copied from interface:SubscriberManagement
Use to register a subscriber- Specified by:
createSubscription
in interfaceSubscriberManagement<java.lang.Object>
- Parameters:
subscriber
- (undocumented)- Returns:
- (undocumented)
-
demandAvailable
public boolean demandAvailable()
- Specified by:
demandAvailable
in interfaceOutputs
-
demandCount
public long demandCount()
- Specified by:
demandCount
in interfaceOutputs
-
downstreamRunning
protected scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> downstreamRunning()
-
enqueueOutputElement
public void enqueueOutputElement(java.lang.Object elem)
- Specified by:
enqueueOutputElement
in interfaceOutputs
-
exposedPublisher
protected ActorPublisher<java.lang.Object> exposedPublisher()
-
exposedPublisher_$eq
protected void exposedPublisher_$eq(ActorPublisher<java.lang.Object> x$1)
-
initialBufferSize
public int initialBufferSize()
- Specified by:
initialBufferSize
in interfaceSubscriberManagement<java.lang.Object>
-
maxBufferSize
public int maxBufferSize()
- Specified by:
maxBufferSize
in interfaceSubscriberManagement<java.lang.Object>
-
pump
public Pump pump()
-
requestFromUpstream
protected void requestFromUpstream(long elements)
Description copied from interface:SubscriberManagement
called when we are ready to consume more elements from our upstream MUST NOT call pushToDownstream- Specified by:
requestFromUpstream
in interfaceSubscriberManagement<java.lang.Object>
- Parameters:
elements
- (undocumented)
-
shutdown
protected void shutdown(boolean completed)
Description copied from interface:SubscriberManagement
called when the spi.Publisher/Processor is ready to be shut down- Specified by:
shutdown
in interfaceSubscriberManagement<java.lang.Object>
- Parameters:
completed
- (undocumented)
-
subreceive
public SubReceive subreceive()
- Specified by:
subreceive
in interfaceOutputs
-
waitingExposedPublisher
protected scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> waitingExposedPublisher()
-
-