F# FormattingSlidingWindowAgent<'T>
Agent that implements the "sliding window" functionality. It collects messages added using the Enqueue method and emits them in overlapping groups of the specified size. For example, given [1,2,3,4,5...] and a size 3, the produced groups will be [1,2,3], [2,3,4], [3,4,5], ...
Constructors
| Constructor | Description |
new(windowSize, cancelToken)
Signature: (windowSize:int * cancelToken:CancellationToken option) -> SlidingWindowAgent<'T>
|
|
Instance members
| Instance member | Description |
add_WindowProduced(arg1)
Signature: (Handler<'T []>) -> unit
|
The event is triggered when a group of messages is collected. The size of the group is exactly 'count' and the values are returned in a fresh array. |
Enqueue(v)
Signature: v:'T -> unit
|
Sends new message to the agent |
remove_WindowProduced(arg1)
Signature: (Handler<'T []>) -> unit
|
The event is triggered when a group of messages is collected. The size of the group is exactly 'count' and the values are returned in a fresh array. |
WindowProduced
Signature: IEvent<'T []>
|
The event is triggered when a group of messages is collected. The size of the group is exactly 'count' and the values are returned in a fresh array. |
