Click or drag to resize
Akka.NETSubFlowOperationsSlidingTOut, TMat, TClosed Method
Apply a sliding window over the stream and return the windows as groups of elements, with the last group possibly smaller than requested due to end-of-stream. n must be positive, otherwise IllegalArgumentException is thrown. step must be positive, otherwise IllegalArgumentException is thrown.

Emits when enough elements have been collected within the window or upstream completed

Backpressures when a window has been assembled and downstream backpressures

Completes when upstream completes

Cancels when downstream cancels

Namespace:  Akka.Streams.Dsl
Assembly:  Akka.Streams (in Akka.Streams.dll) Version: 1.2.3.129 (1.2.3.129)
Syntax
public static SubFlow<IEnumerable<TOut>, TMat, TClosed> Sliding<TOut, TMat, TClosed>(
	this SubFlow<TOut, TMat, TClosed> flow,
	int n,
	int step = 1
)

Parameters

flow
Type: Akka.Streams.DslSubFlowTOut, TMat, TClosed
TBD
n
Type: SystemInt32
TBD
step (Optional)
Type: SystemInt32
TBD

Type Parameters

TOut
TBD
TMat
TBD
TClosed
TBD

Return Value

Type: SubFlowIEnumerableTOut, TMat, TClosed
TBD

Usage Note

In Visual Basic and C#, you can call this method as an instance method on any object of type SubFlowTOut, TMat, TClosed. 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).
Exceptions
ExceptionCondition
ArgumentExceptionThrown when n or step is less than or equal zero.
See Also