Class ActorMaterializerImpl
Default implementation of ActorMaterializer.
Inherited Members
Namespace: Akka.Streams.Implementation
Assembly: Akka.Streams.dll
Syntax
public sealed class ActorMaterializerImpl : ExtendedActorMaterializer, IMaterializer, IMaterializerLoggingProvider, IDisposable
Constructors
| Edit this page View SourceActorMaterializerImpl(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
| Edit this page View SourceExecutionContext
TBD
Declaration
public override MessageDispatcher ExecutionContext { get; }
Property Value
Type | Description |
---|---|
MessageDispatcher |
Overrides
| Edit this page View SourceIsShutdown
TBD
Declaration
public override bool IsShutdown { get; }
Property Value
Type | Description |
---|---|
bool |
Overrides
| Edit this page View SourceSettings
TBD
Declaration
public override ActorMaterializerSettings Settings { get; }
Property Value
Type | Description |
---|---|
ActorMaterializerSettings |
Overrides
| Edit this page View SourceSystem
TBD
Declaration
public override ActorSystem System { get; }
Property Value
Type | Description |
---|---|
ActorSystem |
Overrides
Methods
| Edit this page View SourceEffectiveSettings(Attributes)
TBD
Declaration
public override ActorMaterializerSettings EffectiveSettings(Attributes attributes)
Parameters
Type | Name | Description |
---|---|---|
Attributes | attributes | TBD |
Returns
Type | Description |
---|---|
ActorMaterializerSettings | TBD |
Overrides
| Edit this page View SourceMakeLogger(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
| Edit this page View SourceMaterialize<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
| Edit this page View SourceMaterialize<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
| Edit this page View SourceMaterialize<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<GraphInterpreterShell, IActorRef> | subFlowFuser | TBD |
Returns
Type | Description |
---|---|
TMat | TBD |
Type Parameters
Name | Description |
---|---|
TMat | TBD |
Overrides
| Edit this page View SourceMaterialize<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<GraphInterpreterShell, IActorRef> | subFlowFuser | TBD |
Attributes | initialAttributes | TBD |
Returns
Type | Description |
---|---|
TMat | TBD |
Type Parameters
Name | Description |
---|---|
TMat | TBD |
Overrides
Exceptions
Type | Condition |
---|---|
IllegalStateException | TBD |
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
| Edit this page View SourceScheduleRepeatedly(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
| Edit this page View SourceShutdown()
TBD
Declaration
public override void Shutdown()
Overrides
| Edit this page View SourceWithNamePrefix(string)
TBD
Declaration
public override IMaterializer WithNamePrefix(string name)
Parameters
Type | Name | Description |
---|---|---|
string | name | TBD |
Returns
Type | Description |
---|---|
IMaterializer | TBD |