FanoutProcessorImpl

java.lang.Object
- akka.stream.impl.ActorProcessorImpl
- - akka.stream.impl.FanoutProcessorImpl

All Implemented Interfaces:: Actor, ActorLogging, Pump

public class FanoutProcessorImpl
extends ActorProcessorImpl

INTERNAL API

Nested Class Summary
- Nested classes/interfaces inherited from class akka.stream.impl.ActorProcessorImpl
  ActorProcessorImpl.SubscriptionTimeout$
- Nested classes/interfaces inherited from interface akka.actor.Actor
  Actor.emptyBehavior$, Actor.ignoringBehavior$

Constructor Summary

Constructors
Constructor Description

FanoutProcessorImpl(Attributes attributes)

Method Summary

All Methods Static Methods Instance Methods Concrete Methods
Modifier and Type	Method	Description
`void`	`afterFlush()`
`void`	`postStop()`	User overridable callback.
`FanoutOutputs`	`primaryOutputs()`
`static Props`	`props(Attributes attributes)`
`void`	`pumpFinished()`
`TransferPhase`	`running()`
`scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit>`	`subTimeoutHandling()`
`scala.concurrent.duration.FiniteDuration`	`timeout()`
`StreamSubscriptionTimeoutTerminationMode`	`timeoutMode()`
`OptionVal<Cancellable>`	`timeoutTimer()`

Methods inherited from class akka.stream.impl.ActorProcessorImpl
activeReceive, akka$actor$Actor$_setter_$context_$eq, akka$actor$Actor$_setter_$self_$eq, akka$stream$impl$Pump$_setter_$completedPhase_$eq, completedPhase, context, fail, onError, postRestart, primaryInputs, pumpFailed, receive, self

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface akka.actor.Actor
aroundPostRestart, aroundPostStop, aroundPreRestart, aroundPreStart, aroundReceive, preRestart, preStart, sender, supervisorStrategy, unhandled

Methods inherited from interface akka.actor.ActorLogging
_log_$eq, log

Methods inherited from interface akka.stream.impl.Pump
currentAction_$eq, gotUpstreamSubscription, initialPhase, isPumpFinished, nextPhase, pump, transferState_$eq, waitForUpstreams

- Constructor Detail
  - FanoutProcessorImpl
```
public FanoutProcessorImpl(Attributes attributes)
```
- Method Detail
  - props
```
public static Props props(Attributes attributes)
```
  - timeout
```
public scala.concurrent.duration.FiniteDuration timeout()
```
  - timeoutMode
```
public StreamSubscriptionTimeoutTerminationMode timeoutMode()
```
  - timeoutTimer
```
public OptionVal<Cancellable> timeoutTimer()
```
  - primaryOutputs
```
public FanoutOutputs primaryOutputs()
```
    Overrides:
    
    primaryOutputs in class ActorProcessorImpl
  - running
```
public TransferPhase running()
```
  - pumpFinished
```
public void pumpFinished()
```
    Specified by:
    
    pumpFinished in interface Pump
    
    Overrides:
    
    pumpFinished in class ActorProcessorImpl
  - postStop
```
public void postStop()
```
    Description copied from interface: Actor
    
    User overridable callback.
    Is called asynchronously after 'actor.stop()' is invoked. Empty default implementation.
    
    Specified by:
    
    postStop in interface Actor
    
    Overrides:
    
    postStop in class ActorProcessorImpl
  - afterFlush
```
public void afterFlush()
```
  - subTimeoutHandling
```
public scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> subTimeoutHandling()
```
    Specified by:
    
    subTimeoutHandling in class ActorProcessorImpl