Sha256: b29f1c1e49525c1c24b3af1dc52b5e861d64b6bb1bd37d646d9c83b261820400
Contents?: true
Size: 532 Bytes
Versions: 14
Compression:
Stored size: 532 Bytes
Contents
/**
* Invokes the asynchronous function, surfacing the result through an observable sequence.
* @param {Function} functionAsync Asynchronous function which returns a Promise to run.
* @returns {Observable} An observable sequence exposing the function's result value, or an exception.
*/
Observable.startAsync = function (functionAsync) {
var promise;
try {
promise = functionAsync();
} catch (e) {
return observableThrow(e);
}
return observableFromPromise(promise);
}
Version data entries
14 entries across 7 versions & 1 rubygems