Polling
Namespace: fszmq
Contains methods for working with ZMQ's polling capabilities
Functions and values
| Function or value | Description |
poll timeout items
Signature: timeout:int64<'unit> -> items:seq<Poll> -> bool
Type parameters: 'unit
|
Performs a single polling run
across the given sequence of Poll items, waiting up to the given timeout.
Returns true when one or more callbacks have been invoked, returns false otherwise.
Note: All items passed to Polling.poll MUST share the same context
and belong to the thread calling Polling.poll.
This function is named DoPoll in compiled assemblies.
If you are accessing the function from a language other than F#, or through reflection, use this name.
CompiledName: DoPoll
|
pollForever items
Signature: items:seq<Poll> -> bool
|
Calls Polling.poll with the given sequence of Poll items and no timeout,
effectively causing the polling loop to block indefinitely.
CompiledName: PollForever
|
pollIn fn socket
Signature: fn:(Socket -> unit) -> socket:Socket -> Poll
|
Creates a Poll item for the socket which will
invoke the callback when the socket receives a message
CompiledName: PollIn
|
pollIO fn socket
Signature: fn:(Socket -> unit) -> socket:Socket -> Poll
|
Creates a Poll item for the socket which will
invoke the callback when the socket sends or receives messages
CompiledName: PollIO
|
pollNow items
Signature: items:seq<Poll> -> bool
|
Calls Polling.poll with the given sequence of Poll items and 0 microseconds timeout
CompiledName: PollNow
|
pollOut fn socket
Signature: fn:(Socket -> unit) -> socket:Socket -> Poll
|
Creates a Poll item for the socket which will
invoke the callback when the socket sends a message
CompiledName: PollOut
|
tryPollInput timeout socket
Signature: timeout:int64<'unit> -> socket:Socket -> byte [] [] option
Type parameters: 'unit
|
Polls the given socket, up to the given timeout, for an input message.
Returns a byte[][] option, where None indicates no message was received.
CompiledName: TryPollInput
|