akka.stream.impl

Class SimpleOutputs

java.lang.Object

akka.stream.impl.SimpleOutputs

All Implemented Interfaces:

DefaultOutputTransferStates, Outputs

Direct Known Subclasses:

FanOut.FanoutOutputs

public class SimpleOutputs
extends java.lang.Object
implements DefaultOutputTransferStates

INTERNAL API

Constructor Summary

Constructors

Constructor and Description
SimpleOutputs(ActorRef actor, Pump pump)

Method Summary

Modifier and Type	Method and Description
ActorRef	actor()
void	cancel()
void	complete()
protected org.reactivestreams.Subscription	createSubscription()
boolean	demandAvailable()
long	demandCount()
protected boolean	downstreamCompleted()
protected long	downstreamDemand()
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()
boolean	isClosed()
boolean	isSubscribed()
TransferState	NeedsDemand()
Pump	pump()
SubReceive	subreceive()
protected org.reactivestreams.Subscriber<java.lang.Object>	subscriber()
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.Outputs

isOpen

Constructor Detail

SimpleOutputs

public SimpleOutputs(ActorRef actor,
                     Pump pump)

Method Detail

NeedsDemand

public TransferState NeedsDemand()

Specified by:

NeedsDemand in interface DefaultOutputTransferStates

Specified by:

NeedsDemand in interface Outputs

actor

public ActorRef actor()

pump

public Pump pump()

exposedPublisher

protected ActorPublisher<java.lang.Object> exposedPublisher()

subscriber

protected org.reactivestreams.Subscriber<java.lang.Object> subscriber()

downstreamDemand

protected long downstreamDemand()

downstreamCompleted

protected boolean downstreamCompleted()

demandAvailable

public boolean demandAvailable()

Specified by:

demandAvailable in interface Outputs

demandCount

public long demandCount()

Specified by:

demandCount in interface Outputs

subreceive

public SubReceive subreceive()

Specified by:

subreceive in interface Outputs

isSubscribed

public boolean isSubscribed()

enqueueOutputElement

public void enqueueOutputElement(java.lang.Object elem)

Specified by:

enqueueOutputElement in interface Outputs

complete

public void complete()

Specified by:

complete in interface Outputs

cancel

public void cancel()

Specified by:

cancel in interface Outputs

error

public void error(java.lang.Throwable e)

Specified by:

error in interface Outputs

isClosed

public boolean isClosed()

Specified by:

isClosed in interface Outputs

createSubscription

protected org.reactivestreams.Subscription createSubscription()

waitingExposedPublisher

protected scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> waitingExposedPublisher()

downstreamRunning

protected scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> downstreamRunning()