Rx.Observable.startAsync(functionAsync)
调用异步函数,通过可观察的序列来显示结果。
P.S. 我一开始也不明白,这和
start
方法有什么区别呢,原来一个是异步地
调用函数,一个是 调用异步函数
。
参数
functionAsync
(Function
): 返回一个 Promise 异步函数
返回值
(Observable
): 一个可观察的序列,暴露Promises函数的值或错误。
例
var source = Rx.Observable.startAsync(function () {
return RSVP.Promise.resolve(42);
});
var subscription = source.subscribe(
function (x) {
console.log('Next: ' + x);
},
function (err) {
console.log('Error: ' + err);
},
function () {
console.log('Completed');
});
// => Next: 42
// => Completed