BatchProcessingAgent<'T>
Namespace: FSharpx.Control
Agent that can be used to implement batch processing. It creates groups of messages (added using the Enqueue method) and emits them using the BatchProduced event. A group is produced when it reaches the maximal size or after the timeout elapses.
Constructors
| Constructor | Description |
new(batchSize, timeout)
Signature: (batchSize:int * timeout:int) -> BatchProcessingAgent<'T>
|
CompiledName: |
Instance members
| Instance member | Description |
add_BatchProduced(arg1)
Signature: (Handler<'T []>) -> unit
|
The event is triggered when a group of messages is collected. The group is not empty, but may not be of the specified maximal size (when the timeout elapses before enough messages is collected) |
BatchProduced
Signature: IEvent<'T []>
|
The event is triggered when a group of messages is collected. The group is not empty, but may not be of the specified maximal size (when the timeout elapses before enough messages is collected) CompiledName: |
Enqueue(v)
Signature: v:'T -> unit
|
Sends new message to the agent |
remove_BatchProduced(arg1)
Signature: (Handler<'T []>) -> unit
|
The event is triggered when a group of messages is collected. The group is not empty, but may not be of the specified maximal size (when the timeout elapses before enough messages is collected) |
