从异步类构造函数创建可观察的对象

Question

所以我们有一个像这样的异步类构造函数

class Task {
    constructor(name, url) {
        return (async () => {
             this.name = name;
             this.response = await fetch(url);
             return this;             
        })();
    }
}

然后，我们想在这样的可观察链中使用它

Observable.of({name: "Task1", url: "http://example.com"})
    .pipe(
        switchMap(item =>
            fromPromise(new Task(item.name, item.url)),
            (item, task) => ({item, task})
        )
    ).subscribe();

构造函数按预期运行。我已经尝试过fromPromise和defer，以获得构造函数的返回结果。用tap查看异步构造函数是否发出过。没有。

有帮助吗？

Answer 1

所以问题出在Rx.js 5 vs 6。

Rx.js 6中没有fromPromise。

这是正确的方法，感谢您的评论

Observable.of({name: "Task1", url: "http://example.com"})
    .pipe(
        switchMap(item =>
            from(new Task(item.name, item.url)),
            (item, task) => ({item, task})
        )
    ).subscribe();