 | SubFlowOperations.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)
Syntaxpublic 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.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
See Also