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
All Methods Instance Methods Concrete Methods 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
-
-
-
-
Method Detail
-
NeedsDemand
public TransferState NeedsDemand()
- Specified by:
NeedsDemand
in interfaceDefaultOutputTransferStates
- Specified by:
NeedsDemand
in interfaceOutputs
-
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 interfaceDefaultOutputTransferStates
-
createSubscription
protected org.reactivestreams.Subscription createSubscription()
-
demandAvailable
public boolean demandAvailable()
- Specified by:
demandAvailable
in interfaceOutputs
-
demandCount
public long demandCount()
- Specified by:
demandCount
in interfaceOutputs
-
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 interfaceOutputs
-
exposedPublisher
protected ActorPublisher<java.lang.Object> exposedPublisher()
-
exposedPublisher_$eq
protected void exposedPublisher_$eq(ActorPublisher<java.lang.Object> x$1)
-
isSubscribed
public boolean isSubscribed()
-
pump
public Pump pump()
-
subreceive
public SubReceive subreceive()
- Specified by:
subreceive
in interfaceOutputs
-
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()
-
-