type window
Returns an async transformer that produces windows/collections of windowSize
size, each window starting skipAmount
of elements after the previous, and optionally collected by a custom reducer.
example
await AsyncStream.of(1, 2, 3, 4, 5, 6)
.transform(AsyncTransformer.window(3))
.toArray()
// => [[1, 2, 3], [4, 5, 6]]
Definition
window: {
<T>(windowSize: number, skipAmount?: number):
AsyncTransformer
<T, T[]>;
<T, R>(windowSize: number, skipAmount?: number, collector?: AsyncReducer<T, R>):
AsyncTransformer
<T, R>;
}