Async
Namespace: MBrace.Core.Internals
Parent Module: AsyncExtensions
Static members
| Static member | Description |
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. |
