Member | Description |
member DefaultTimeout : int | |
member DefaultTimeout : int with set | |
member Post : 'msg -> unit |
Post a message to the message queue of the MailboxProcessor, asynchronously
|
member
PostAndReply : (AsyncReplyChannel<'reply> -> 'msg) * ?timeout:int *
?exitContext:bool -> 'reply |
Post a message to the message queue of the MailboxProcessor and await a reply on the channel
|
member
PostAndReplyAsync : (AsyncReplyChannel<'reply> -> 'msg) * ?timeout:int *
?exitContext:bool -> Async<'reply> |
Post a message to the message queue of the MailboxProcessor and await an eventual reply on the channel. Return None if timeout exceeded.
|
member Receive : ?timeout:int -> Async<'msg> |
Return an asynchronous computation which will
consume the first message in arrival order. No thread
is blocked while waiting for further messages. Raise a TimeoutException
if the timeout is exceeded.
|
member Scan : scanner:('msg -> Async<'res> option) * ?timeout:int -> Async<'res> |
Return an asynchronous computation which will
look through messages in arrival order until 'scanner' returns a Some value. No thread
is blocked while waiting for further messages. Raise a TimeoutException
if the timeout is exceeded.
|
member Start : unit -> unit |
Start the MailboxProcessor
|
member
TryPostAndReply : (AsyncReplyChannel<'reply> -> 'msg) * ?timeout:int *
?exitContext:bool -> 'reply option |
Post a message to the message queue of the MailboxProcessor and await a reply on the channel
|
member
TryPostAndReplyAsync : (AsyncReplyChannel<'reply> -> 'msg) * ?timeout:int *
?exitContext:bool -> Async<'reply option> |
Post a message to the message queue of the MailboxProcessor and eventually await a reply on the channel. Return None if timeout exceeded.
|
member TryReceive : ?timeout:int -> Async<'msg option> |
Return an asynchronous computation which will
consume the first message in arrival order. No thread
is blocked while waiting for further messages. Return None
if the timeout is exceeded.
|
member
TryScan : scanner:('msg -> Async<'res> option) * ?timeout:int ->
Async<'res option> |
Return an asynchronous computation which will
look through messages in arrival order until 'scanner' returns a Some value. No thread
is blocked while waiting for further messages. Return None
if the timeout is exceeded.
|
member UnsafeMessageQueueContents : seq<'msg> | |