Class FanIn<T>

TBD

Inheritance

object

ActorBase

FanIn<T>

Implements

IInternalActor

IPump

Inherited Members

ActorBase.Sender

ActorBase.Self

ActorBase.Context

ActorBase.AroundReceive(Receive, object)

ActorBase.EmptyReceive

ActorBase.Unhandled(object)

ActorBase.Become(Receive)

ActorBase.BecomeStacked(Receive)

ActorBase.UnbecomeStacked()

ActorBase.SetReceiveTimeout(TimeSpan?)

ActorBase.AroundPreRestart(Exception, object)

ActorBase.AroundPreStart()

ActorBase.PreStart()

ActorBase.AroundPostRestart(Exception, object)

ActorBase.PreRestart(Exception, object)

ActorBase.AroundPostStop()

ActorBase.SupervisorStrategy()

object.Equals(object)

object.Equals(object, object)

object.GetHashCode()

object.GetType()

object.MemberwiseClone()

object.ReferenceEquals(object, object)

object.ToString()

Namespace: Akka.Streams.Implementation

Assembly: Akka.Streams.dll

Syntax

public abstract class FanIn<T> : ActorBase, IInternalActor, IPump

Type Parameters

Name	Description
T	TBD

Constructors

FanIn(ActorMaterializerSettings, int)

TBD

Declaration

protected FanIn(ActorMaterializerSettings settings, int inputCount)

Parameters

Type	Name	Description
ActorMaterializerSettings	settings	TBD
int	inputCount	TBD

Exceptions

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

Fields

InputBunch

TBD

Declaration

protected readonly InputBunch InputBunch

Field Value

Type	Description
InputBunch

InputCount

TBD

Declaration

protected readonly int InputCount

Field Value

Type	Description
int

PrimaryOutputs

TBD

Declaration

protected readonly SimpleOutputs PrimaryOutputs

Field Value

Type	Description
SimpleOutputs

Settings

TBD

Declaration

protected readonly ActorMaterializerSettings Settings

Field Value

Type	Description
ActorMaterializerSettings

Properties

CurrentAction

TBD

Declaration

public Action CurrentAction { get; set; }

Property Value

Type	Description
Action

IsPumpFinished

TBD

Declaration

public bool IsPumpFinished { get; }

Property Value

Type	Description
bool

Log

TBD

Declaration

protected ILoggingAdapter Log { get; }

Property Value

Type	Description
ILoggingAdapter

TransferState

TBD

Declaration

public TransferState TransferState { get; set; }

Property Value

Type	Description
TransferState

Methods

Fail(Exception)

TBD

Declaration

protected void Fail(Exception cause)

Parameters

Type	Name	Description
Exception	cause	TBD

GotUpstreamSubscription()

TBD

Declaration

public void GotUpstreamSubscription()

InitialPhase(int, TransferPhase)

TBD

Declaration

public void InitialPhase(int waitForUpstream, TransferPhase andThen)

Parameters

Type	Name	Description
int	waitForUpstream	TBD
TransferPhase	andThen	TBD

NextPhase(TransferPhase)

TBD

Declaration

public void NextPhase(TransferPhase phase)

Parameters

Type	Name	Description
TransferPhase	phase	TBD

PostRestart(Exception)

TBD

Declaration

protected override void PostRestart(Exception reason)

Parameters

Type	Name	Description
Exception	reason	TBD

Overrides

ActorBase.PostRestart(Exception)

Exceptions

Type	Condition
IllegalStateException	TBD This exception is thrown automatically since the actor cannot be restarted.

PostStop()

TBD

Declaration

protected override void PostStop()

Overrides

ActorBase.PostStop()

Pump()

TBD

Declaration

public void Pump()

PumpFailed(Exception)

TBD

Declaration

public void PumpFailed(Exception e)

Parameters

Type	Name	Description
Exception	e	TBD

PumpFinished()

TBD

Declaration

public void PumpFinished()

Receive(object)

TBD

Declaration

protected override bool Receive(object message)

Parameters

Type	Name	Description
object	message	TBD

Returns

Type	Description
bool	TBD

Overrides

ActorBase.Receive(object)

WaitForUpstream(int)

TBD

Declaration

public void WaitForUpstream(int waitForUpstream)

Parameters

Type	Name	Description
int	waitForUpstream	TBD

Implements

IInternalActor

IPump

Extension Methods

ObjectExtensions.IsDefaultForType<T>(T)

ObjectExtensions.AsOption<T>(T)

Extensions.AsInstanceOf<T>(object)