Class ActorAttributes

Attributes for the ActorMaterializer. Note that more attributes defined in Attributes.

Inheritance
object
ActorAttributes
Inherited Members
Namespace: Akka.Streams
Assembly: Akka.Streams.dll
Syntax
public static class ActorAttributes

Properties

| Edit this page View Source

IODispatcher

Declaration
public static ActorAttributes.Dispatcher IODispatcher { get; }
Property Value
Type Description
ActorAttributes.Dispatcher

Methods

| Edit this page View Source

CreateDebugLogging(bool)

Enables additional low level troubleshooting logging at DEBUG log level

Declaration
public static Attributes CreateDebugLogging(bool enabled)
Parameters
Type Name Description
bool enabled
Returns
Type Description
Attributes
| Edit this page View Source

CreateDispatcher(string)

Specifies the name of the dispatcher. This also adds an async boundary.

Declaration
public static Attributes CreateDispatcher(string dispatcherName)
Parameters
Type Name Description
string dispatcherName

TBD
Returns
Type Description
Attributes

TBD
| Edit this page View Source

CreateFuzzingMode(bool)

Test utility: fuzzing mode means that GraphStage events are not processed in FIFO order within a fused subgraph, but randomized.

Declaration
public static Attributes CreateFuzzingMode(bool enabled)
Parameters
Type Name Description
bool enabled
Returns
Type Description
Attributes
| Edit this page View Source

CreateMaxFixedBufferSize(int)

Configure the maximum buffer size for which a FixedSizeBuffer will be preallocated. This defaults to a large value because it is usually better to fail early when system memory is not sufficient to hold the buffer.

Declaration
public static Attributes CreateMaxFixedBufferSize(int size)
Parameters
Type Name Description
int size
Returns
Type Description
Attributes
| Edit this page View Source

CreateOutputBurstLimit(int)

Maximum number of elements emitted in batch if downstream signals large demand.

Declaration
public static Attributes CreateOutputBurstLimit(int limit)
Parameters
Type Name Description
int limit
Returns
Type Description
Attributes
| Edit this page View Source

CreateStreamSubscriptionTimeout(TimeSpan, StreamSubscriptionTimeoutTerminationMode)

Defines a timeout for stream subscription and what action to take when that hits.

Declaration
public static Attributes CreateStreamSubscriptionTimeout(TimeSpan timeout, StreamSubscriptionTimeoutTerminationMode mode)
Parameters
Type Name Description
TimeSpan timeout
StreamSubscriptionTimeoutTerminationMode mode
Returns
Type Description
Attributes
| Edit this page View Source

CreateSupervisionStrategy(Decider)

Decides how exceptions from user are to be handled

Stages supporting supervision strategies explicitly document that they do so. If a stage does not document support for these, it should be assumed it does not support supervision.

Declaration
public static Attributes CreateSupervisionStrategy(Decider strategy)
Parameters
Type Name Description
Decider strategy

TBD
Returns
Type Description
Attributes

TBD
| Edit this page View Source

CreateSyncProcessingLimit(int)

Limit for number of messages that can be processed synchronously in stream to substream communication

Declaration
public static Attributes CreateSyncProcessingLimit(int limit)
Parameters
Type Name Description
int limit
Returns
Type Description
Attributes