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 Description
  
  FanoutOutputs(int id, ActorRef _impl, Pump _pump)
- Method Summary
  
  All Methods Instance Methods Concrete Methods
  Modifier and Type Method Description
  
  org.reactivestreams.Subscription createSubscription()
  
  int id()
  - Methods inherited from class akka.stream.impl.SimpleOutputs
    actor, akka$stream$impl$DefaultOutputTransferStates$_setter_$NeedsDemand_$eq, cancel, complete, demandAvailable, demandCount, downstreamCompleted, downstreamCompleted_$eq, downstreamDemand, downstreamDemand_$eq, downstreamRunning, enqueueOutputElement, error, exposedPublisher, exposedPublisher_$eq, isClosed, isSubscribed, NeedsDemand, pump, subreceive, subscriber, subscriber_$eq, 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
- createSubscription
```
public org.reactivestreams.Subscription createSubscription()
```
  Overrides:
  
  createSubscription in class SimpleOutputs
- id
```
public int id()
```