Click or drag to resize
Akka.NETFlowOperationsBufferTIn, TOut, TMat Method
Adds a fixed size buffer in the flow that allows to store elements from a faster upstream until it becomes full. Depending on the defined OverflowStrategy it might drop elements or backpressure the upstream if there is no space available

Emits when downstream stops backpressuring and there is a pending element in the buffer

Backpressures when depending on OverflowStrategy

* Backpressure - backpressures when buffer is full

* DropHead, DropTail, DropBuffer - never backpressures

* Fail - fails the stream if buffer gets full

Completes when upstream completes and buffered elements has been drained

Cancels when downstream cancels

Namespace:  Akka.Streams.Dsl
Assembly:  Akka.Streams (in Akka.Streams.dll) Version: 1.2.3.42 (1.2.3.42)
Syntax
public static Flow<TIn, TOut, TMat> Buffer<TIn, TOut, TMat>(
	this Flow<TIn, TOut, TMat> flow,
	int size,
	OverflowStrategy strategy
)

Parameters

flow
Type: Akka.Streams.DslFlowTIn, TOut, TMat
TBD
size
Type: SystemInt32
The size of the buffer in element count
strategy
Type: Akka.StreamsOverflowStrategy
Strategy that is used when incoming elements cannot fit inside the buffer

Type Parameters

TIn
TBD
TOut
TBD
TMat
TBD

Return Value

Type: FlowTIn, TOut, TMat
TBD

Usage Note

In Visual Basic and C#, you can call this method as an instance method on any object of type FlowTIn, TOut, TMat. When you use instance method syntax to call this method, omit the first parameter. For more information, see Extension Methods (Visual Basic) or Extension Methods (C# Programming Guide).
See Also