| SubFlowOperationsSlidingTOut, 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
)
[<ExtensionAttribute>]
static member Sliding :
flow : SubFlow<'TOut, 'TMat, 'TClosed> *
n : int *
?step : int
(* Defaults:
let _step = defaultArg step 1
*)
-> SubFlow<IEnumerable<'TOut>, 'TMat, 'TClosed>
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,
TClosedTBD
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 See Also