MBrace.Core


Async

Namespace: MBrace.Core.Internals
Parent Module: AsyncExtensions

Static members

Static memberDescription
AwaitObservable(...)
Signature: (observable:IObservable<'T> * timeoutMilliseconds:int option) -> Async<'T>
Type parameters: 'T

Asynchronously await an IObservable to yield results. Returns the first value to be observed.

AwaitTaskCorrect(task)
Signature: task:Task -> Async<unit>

Gets the result of given task so that in the event of exception the actual user exception is raised as opposed to being wrapped in a System.AggregateException.

AwaitTaskCorrect(task)
Signature: task:Task<'T> -> Async<'T>
Type parameters: 'T

Gets the result of given task so that in the event of exception the actual user exception is raised as opposed to being wrapped in a System.AggregateException.

Raise(e)
Signature: e:exn -> Async<'T>
Type parameters: 'T

Efficiently reraise exception, without losing its existing stacktrace.

RunSync(workflow, cancellationToken)
Signature: (workflow:Async<'T> * cancellationToken:CancellationToken option) -> 'T
Type parameters: 'T

Runs the asynchronous computation and awaits its result. Preserves original stacktrace for any exception raised.

WithTimeout(...)
Signature: (workflow:Async<'T> * timeoutMilliseconds:int option) -> Async<'T>
Type parameters: 'T

Runs provided workflow with timeout.

Fork me on GitHub