在以下示例中,toPromise
不起作用:
https://jsfiddle.net/tossp/nmf9jg32/
我的代码:
function getPostData() {
return fetch('https://jsonplaceholder.typicode.com/posts/1')
.then(res => res.json())
}
var source = Rx.Observable.fromEvent(document.body, 'click');
var example = source.concatMap(
e => Rx.Observable.from(getPostData()),
(e, res, eIndex, resIndex) => res.title);
example.subscribe({
next: (value) => { console.log('subscribe!!!',value); },
error: (err) => { console.log('Error: ' + err); },
complete: () => { console.log('complete'); }
});
example.do((value)=>console.log('do!!!',value)).toPromise().then((value)=>console.log('toPromise!!!',value));
最佳答案
已经解决https://github.com/ReactiveX/rxjs/issues/2536
toPromise
本质上是 observable.last().subscribe()
如果您在调用 toPromise
之前添加 .take(1)
,那么事情就会开始起作用。
即
example.do((value)=>console.log('do!!!',value)).take(1).toPromise()
关于javascript - rxjs5 toPromise 不工作,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/43313799/