Observable 完成后返回单个对象

Question

我有一个带有几个元素（字体）的 Observable

myFontsObservable = Observable.of<Font>(new Font("font1"), new Font("font2"));

现在我想订阅这个 Observable，处理所有的 Fonts 并将它们注册到一个 Document 中，然后在处理完所有这些之后，返回 Document

public registerFonts(myFontsObservable): Observable<Document> {
    doc = new Document();
    myFontsObservable.subscribe(
        font => doc.register(font);
        (err) => {},
        () => return Observable.of(doc);
    );
    // I need to return something here too
}

此代码无法编译，因为我还需要在订阅之外返回一些内容。但是，如果我在那里返回一些东西，那么当我调用 registerFonts(...) 时，我会得到错误的值，因为它还没有完成

我该怎么做？

Answer 1

你可以试试这些方法

public registerFonts(myFontsObservable): Observable<Document> {
    return myFontsObservable
           .reduce((doc, font) => {
              doc.register(font);
              return doc
           }, new Document())
}

Answer 2

使用 mergeMap 运算符（可管道）。

这个操作符会处理第一个 observable 的结果，并且需要返回另一个 observable。我相信这就是你所需要的。

public registerFonts(myFontsObservable): Observable<Document> {
    doc = new Document();
    return myFontsObservable.pipe(
      mergeMap(font => {
        doc.register(font);
        return Observable.of(doc);
      })
    );
}