Package 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	Description
SimpleOutputs(ActorRef actor, Pump pump)

Method Summary

Modifier and Type	Method	Description
ActorRef	actor()
protected void	akka$stream$impl$DefaultOutputTransferStates$_setter_$NeedsDemand_$eq(TransferState x$1)
void	cancel()
void	complete()
protected org.reactivestreams.Subscription	createSubscription()
boolean	demandAvailable()
long	demandCount()
protected boolean	downstreamCompleted()
protected void	downstreamCompleted_$eq(boolean x$1)
protected long	downstreamDemand()
protected void	downstreamDemand_$eq(long x$1)
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)
boolean	isClosed()
boolean	isSubscribed()
TransferState	NeedsDemand()
Pump	pump()
SubReceive	subreceive()
protected org.reactivestreams.Subscriber<java.lang.Object>	subscriber()
protected void	subscriber_$eq(org.reactivestreams.Subscriber<java.lang.Object> x$1)
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()

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 interface DefaultOutputTransferStates

cancel

public void cancel()

Specified by:

cancel in interface Outputs

complete

public void complete()

Specified by:

complete in interface Outputs

createSubscription

protected org.reactivestreams.Subscription createSubscription()

demandAvailable

public boolean demandAvailable()

Specified by:

demandAvailable in interface Outputs

demandCount

public long demandCount()

Specified by:

demandCount in interface Outputs

downstreamCompleted

protected boolean downstreamCompleted()

downstreamCompleted_$eq

protected void downstreamCompleted_$eq(boolean x$1)

downstreamDemand

protected long downstreamDemand()

downstreamDemand_$eq

protected void downstreamDemand_$eq(long x$1)

downstreamRunning

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

enqueueOutputElement

public void enqueueOutputElement(java.lang.Object elem)

Specified by:

enqueueOutputElement in interface Outputs

error

public void error(java.lang.Throwable e)

Specified by:

error in interface Outputs

exposedPublisher

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

exposedPublisher_$eq

protected void exposedPublisher_$eq(ActorPublisher<java.lang.Object> x$1)

isClosed

public boolean isClosed()

Specified by:

isClosed in interface Outputs

isSubscribed

public boolean isSubscribed()

pump

public Pump pump()

subreceive

public SubReceive subreceive()

Specified by:

subreceive in interface Outputs

subscriber

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

subscriber_$eq

protected void subscriber_$eq(org.reactivestreams.Subscriber<java.lang.Object> x$1)

waitingExposedPublisher

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