akka.stream.impl

Class FanOut.FanoutOutputs

java.lang.Object

akka.stream.impl.SimpleOutputs

akka.stream.impl.FanOut.FanoutOutputs

All Implemented Interfaces:

DefaultOutputTransferStates, Outputs

Enclosing class:

FanOut

public static class FanOut.FanoutOutputs
extends SimpleOutputs

Constructor Summary

Constructors

Constructor and Description
FanoutOutputs(int id, ActorRef _impl, Pump _pump)

Method Summary

Modifier and Type	Method and Description
org.reactivestreams.Subscription	createSubscription()
int	id()

Methods inherited from class akka.stream.impl.SimpleOutputs

actor, cancel, complete, demandAvailable, demandCount, downstreamCompleted, downstreamDemand, downstreamRunning, enqueueOutputElement, error, exposedPublisher, isClosed, isSubscribed, NeedsDemand, pump, subreceive, subscriber, 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

FanoutOutputs

public FanoutOutputs(int id,
                     ActorRef _impl,
                     Pump _pump)

Method Detail

id

public int id()

createSubscription

public org.reactivestreams.Subscription createSubscription()

Overrides:

createSubscription in class SimpleOutputs