Click or drag to resize
Akka.NETSubFlowOperations.Sliding<TOut, 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.42 (1.2.3.42)
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.Dsl.SubFlow<TOut, TMat, TClosed>
TBD
n
Type: System.Int32
TBD
step (Optional)
Type: System.Int32
TBD

Type Parameters

TOut
TBD
TMat
TBD
TClosed
TBD

Return Value

Type: SubFlow<IEnumerable<TOut>, TMat, TClosed>
TBD

Usage Note

In Visual Basic and C#, you can call this method as an instance method on any object of type SubFlow<TOut, 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