public class SimpleOutputs extends java.lang.Object implements DefaultOutputTransferStates
Constructor and Description |
---|
SimpleOutputs(ActorRef actor,
Pump pump) |
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() |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
NeedsDemandOrCancel
public TransferState NeedsDemand()
NeedsDemand
in interface DefaultOutputTransferStates
NeedsDemand
in interface Outputs
public ActorRef actor()
public Pump pump()
protected ActorPublisher<java.lang.Object> exposedPublisher()
protected org.reactivestreams.Subscriber<java.lang.Object> subscriber()
protected long downstreamDemand()
protected boolean downstreamCompleted()
public boolean demandAvailable()
demandAvailable
in interface Outputs
public long demandCount()
demandCount
in interface Outputs
public SubReceive subreceive()
subreceive
in interface Outputs
public boolean isSubscribed()
public void enqueueOutputElement(java.lang.Object elem)
enqueueOutputElement
in interface Outputs
protected org.reactivestreams.Subscription createSubscription()
protected scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> waitingExposedPublisher()
protected scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> downstreamRunning()