Class StreamRefAttributes

Attributes for stream refs (ISourceRef<TOut> and ISinkRef<TIn>). Note that more attributes defined in Attributes and ActorAttributes.

Inheritance
Object
StreamRefAttributes
Inherited Members
Namespace: Akka.Streams
Assembly: Akka.Streams.dll
Syntax
public static class StreamRefAttributes

Methods

| Improve this Doc View Source

CreateBufferCapacity(Int32)

Specifies the size of the buffer on the receiving side that is eagerly filled even without demand.

Declaration
public static Attributes CreateBufferCapacity(int capacity)
Parameters
Type Name Description
Int32 capacity
Returns
Type Description
Attributes
| Improve this Doc View Source

CreateDemandRedeliveryInterval(TimeSpan)

If no new elements arrive within this timeout, demand is redelivered.

Declaration
public static Attributes CreateDemandRedeliveryInterval(TimeSpan timeout)
Parameters
Type Name Description
TimeSpan timeout
Returns
Type Description
Attributes
| Improve this Doc View Source

CreateFinalTerminationSignalDeadline(TimeSpan)

The time between the Terminated signal being received and when the local SourceRef determines to fail itself

Declaration
public static Attributes CreateFinalTerminationSignalDeadline(TimeSpan timeout)
Parameters
Type Name Description
TimeSpan timeout
Returns
Type Description
Attributes
| Improve this Doc View Source

CreateSubscriptionTimeout(TimeSpan)

Specifies the subscription timeout within which the remote side MUST subscribe to the handed out stream reference.

Declaration
public static Attributes CreateSubscriptionTimeout(TimeSpan timeout)
Parameters
Type Name Description
TimeSpan timeout
Returns
Type Description
Attributes