Class ActorMaterializerImpl

Default implementation of ActorMaterializer.

Inheritance

Object

ActorMaterializer

ExtendedActorMaterializer

ActorMaterializerImpl

Implements

IMaterializer

IMaterializerLoggingProvider

IDisposable

Inherited Members

ActorMaterializer.DefaultConfig()

ActorMaterializer.Create(IActorRefFactory, ActorMaterializerSettings, String)

ActorMaterializer.Logger

ActorMaterializer.Supervisor

ActorMaterializer.ActorOf(MaterializationContext, Props)

ActorMaterializer.Dispose()

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 sealed class ActorMaterializerImpl : ExtendedActorMaterializer, IMaterializer, IMaterializerLoggingProvider, IDisposable

Constructors

| Improve this Doc View Source

ActorMaterializerImpl(ActorSystem, ActorMaterializerSettings, Dispatchers, IActorRef, AtomicBoolean, EnumerableActorName)

Declaration

public ActorMaterializerImpl(ActorSystem system, ActorMaterializerSettings settings, Dispatchers dispatchers, IActorRef supervisor, AtomicBoolean haveShutDown, EnumerableActorName flowNames)

Parameters

Type	Name	Description
ActorSystem	system
ActorMaterializerSettings	settings
Dispatchers	dispatchers
IActorRef	supervisor
AtomicBoolean	haveShutDown
EnumerableActorName	flowNames

Properties

| Improve this Doc View Source

ExecutionContext

TBD

Declaration

public override MessageDispatcher ExecutionContext { get; }

Property Value

Type	Description
MessageDispatcher

Overrides

ActorMaterializer.ExecutionContext

| Improve this Doc View Source

IsShutdown

TBD

Declaration

public override bool IsShutdown { get; }

Property Value

Type	Description
Boolean

Overrides

ActorMaterializer.IsShutdown

| Improve this Doc View Source

Settings

TBD

Declaration

public override ActorMaterializerSettings Settings { get; }

Property Value

Type	Description
ActorMaterializerSettings

Overrides

ActorMaterializer.Settings

| Improve this Doc View Source

System

TBD

Declaration

public override ActorSystem System { get; }

Property Value

Type	Description
ActorSystem

Overrides

ActorMaterializer.System

Methods

| Improve this Doc View Source

EffectiveSettings(Attributes)

TBD

Declaration

public override ActorMaterializerSettings EffectiveSettings(Attributes attributes)

Parameters

Type	Name	Description
Attributes	attributes	TBD

Returns

Type	Description
ActorMaterializerSettings	TBD

Overrides

ActorMaterializer.EffectiveSettings(Attributes)

| Improve this Doc View Source

MakeLogger(Object)

Creates a new logging adapter.

Declaration

public override ILoggingAdapter MakeLogger(object logSource)

Parameters

Type	Name	Description
Object	logSource	The source that produces the log events.

Returns

Type	Description
ILoggingAdapter	The newly created logging adapter.

Overrides

ActorMaterializer.MakeLogger(Object)

| Improve this Doc View Source

Materialize<TMat>(IGraph<ClosedShape, TMat>)

TBD

Declaration

public override TMat Materialize<TMat>(IGraph<ClosedShape, TMat> runnable)

Parameters

Type	Name	Description
IGraph<ClosedShape, TMat>	runnable	TBD

Returns

Type	Description
TMat	TBD

Type Parameters

Name	Description
TMat	TBD

Overrides

Akka.Streams.ActorMaterializer.Materialize<TMat>(Akka.Streams.IGraph<Akka.Streams.ClosedShape, TMat>)

| Improve this Doc View Source

Materialize<TMat>(IGraph<ClosedShape, TMat>, Attributes)

TBD

Declaration

public override TMat Materialize<TMat>(IGraph<ClosedShape, TMat> runnable, Attributes initialAttributes)

Parameters

Type	Name	Description
IGraph<ClosedShape, TMat>	runnable	TBD
Attributes	initialAttributes	TBD

Returns

Type	Description
TMat	TBD

Type Parameters

Name	Description
TMat	TBD

Overrides

Akka.Streams.ActorMaterializer.Materialize<TMat>(Akka.Streams.IGraph<Akka.Streams.ClosedShape, TMat>, Akka.Streams.Attributes)

| Improve this Doc View Source

Materialize<TMat>(IGraph<ClosedShape, TMat>, Func<GraphInterpreterShell, IActorRef>)

TBD

Declaration

public override TMat Materialize<TMat>(IGraph<ClosedShape, TMat> runnable, Func<GraphInterpreterShell, IActorRef> subFlowFuser)

Parameters

Type	Name	Description
IGraph<ClosedShape, TMat>	runnable	TBD
Func<Akka.Streams.Implementation.Fusing.GraphInterpreterShell, IActorRef>	subFlowFuser	TBD

Returns

Type	Description
TMat	TBD

Type Parameters

Name	Description
TMat	TBD

Overrides

Akka.Streams.Implementation.ExtendedActorMaterializer.Materialize<TMat>(Akka.Streams.IGraph<Akka.Streams.ClosedShape, TMat>, System.Func<Akka.Streams.Implementation.Fusing.GraphInterpreterShell, Akka.Actor.IActorRef>)

| Improve this Doc View Source

Materialize<TMat>(IGraph<ClosedShape, TMat>, Func<GraphInterpreterShell, IActorRef>, Attributes)

TBD

Declaration

public override TMat Materialize<TMat>(IGraph<ClosedShape, TMat> runnable, Func<GraphInterpreterShell, IActorRef> subFlowFuser, Attributes initialAttributes)

Parameters

Type	Name	Description
IGraph<ClosedShape, TMat>	runnable	TBD
Func<Akka.Streams.Implementation.Fusing.GraphInterpreterShell, IActorRef>	subFlowFuser	TBD
Attributes	initialAttributes	TBD

Returns

Type	Description
TMat	TBD

Type Parameters

Name	Description
TMat	TBD

Overrides

Exceptions

Type	Condition
IllegalStateException	TBD

| Improve this Doc View Source

ScheduleOnce(TimeSpan, Action)

TBD

Declaration

public override ICancelable ScheduleOnce(TimeSpan delay, Action action)

Parameters

Type	Name	Description
TimeSpan	delay	TBD
Action	action	TBD

Returns

Type	Description
ICancelable	TBD

Overrides

ActorMaterializer.ScheduleOnce(TimeSpan, Action)

| Improve this Doc View Source

ScheduleRepeatedly(TimeSpan, TimeSpan, Action)

TBD

Declaration

public override ICancelable ScheduleRepeatedly(TimeSpan initialDelay, TimeSpan interval, Action action)

Parameters

Type	Name	Description
TimeSpan	initialDelay	TBD
TimeSpan	interval	TBD
Action	action	TBD

Returns

Type	Description
ICancelable	TBD

Overrides

ActorMaterializer.ScheduleRepeatedly(TimeSpan, TimeSpan, Action)

| Improve this Doc View Source

Shutdown()

TBD

Declaration

public override void Shutdown()

Overrides

ActorMaterializer.Shutdown()

| Improve this Doc View Source

WithNamePrefix(String)

TBD

Declaration

public override IMaterializer WithNamePrefix(string name)

Parameters

Type	Name	Description
String	name	TBD

Returns

Type	Description
IMaterializer	TBD