Class FanIn<T>

TBD

Inheritance
Object
ActorBase
FanIn<T>
Implements
Inherited Members
Namespace: Akka.Streams.Implementation
Assembly: Akka.Streams.dll
Syntax
public abstract class FanIn<T> : ActorBase, IInternalActor, IPump
Type Parameters
Name Description
T

TBD

Constructors

| Improve this Doc View Source

FanIn(ActorMaterializerSettings, Int32)

TBD

Declaration
protected FanIn(ActorMaterializerSettings settings, int inputCount)
Parameters
Type Name Description
ActorMaterializerSettings settings

TBD
Int32 inputCount

TBD
Exceptions
Type Condition
IllegalStateException

This exception is thrown when the pump has not been initialized with a phase.

Fields

| Improve this Doc View Source

InputBunch

TBD

Declaration
protected readonly InputBunch InputBunch
Field Value
Type Description
InputBunch
| Improve this Doc View Source

InputCount

TBD

Declaration
protected readonly int InputCount
Field Value
Type Description
Int32
| Improve this Doc View Source

PrimaryOutputs

TBD

Declaration
protected readonly SimpleOutputs PrimaryOutputs
Field Value
Type Description
SimpleOutputs
| Improve this Doc View Source

Settings

TBD

Declaration
protected readonly ActorMaterializerSettings Settings
Field Value
Type Description
ActorMaterializerSettings

Properties

| Improve this Doc View Source

CurrentAction

TBD

Declaration
public Action CurrentAction { get; set; }
Property Value
Type Description
Action
| Improve this Doc View Source

IsPumpFinished

TBD

Declaration
public bool IsPumpFinished { get; }
Property Value
Type Description
Boolean
| Improve this Doc View Source

Log

TBD

Declaration
protected ILoggingAdapter Log { get; }
Property Value
Type Description
ILoggingAdapter
| Improve this Doc View Source

TransferState

TBD

Declaration
public TransferState TransferState { get; set; }
Property Value
Type Description
TransferState

Methods

| Improve this Doc View Source

Fail(Exception)

TBD

Declaration
protected void Fail(Exception cause)
Parameters
Type Name Description
Exception cause

TBD
| Improve this Doc View Source

GotUpstreamSubscription()

TBD

Declaration
public void GotUpstreamSubscription()
| Improve this Doc View Source

InitialPhase(Int32, TransferPhase)

TBD

Declaration
public void InitialPhase(int waitForUpstream, TransferPhase andThen)
Parameters
Type Name Description
Int32 waitForUpstream

TBD
TransferPhase andThen

TBD
| Improve this Doc View Source

NextPhase(TransferPhase)

TBD

Declaration
public void NextPhase(TransferPhase phase)
Parameters
Type Name Description
TransferPhase phase

TBD
| Improve this Doc View Source

PostRestart(Exception)

TBD

Declaration
protected override void PostRestart(Exception reason)
Parameters
Type Name Description
Exception reason

TBD
Overrides
Exceptions
Type Condition
IllegalStateException

TBD This exception is thrown automatically since the actor cannot be restarted.
| Improve this Doc View Source

PostStop()

TBD

Declaration
protected override void PostStop()
Overrides
| Improve this Doc View Source

Pump()

TBD

Declaration
public void Pump()
| Improve this Doc View Source

PumpFailed(Exception)

TBD

Declaration
public void PumpFailed(Exception e)
Parameters
Type Name Description
Exception e

TBD
| Improve this Doc View Source

PumpFinished()

TBD

Declaration
public void PumpFinished()
| Improve this Doc View Source

Receive(Object)

TBD

Declaration
protected override bool Receive(object message)
Parameters
Type Name Description
Object message

TBD
Returns
Type Description
Boolean

TBD
Overrides
| Improve this Doc View Source

WaitForUpstream(Int32)

TBD

Declaration
public void WaitForUpstream(int waitForUpstream)
Parameters
Type Name Description
Int32 waitForUpstream

TBD

Implements

Extension Methods