如何使用 Observables 而不是 Promise？

Question

我有一个带有一些方法的服务，它们中的大多数都需要完成某个回调才能完成它的工作。使用 Promises，在伪中，很容易做到这一点：

ready = http.get(stuff); // Returns a promise, resolves after a while

methodOne() { // methods sometimes called before promise resolves
    this.ready.then(_ => { 
        // doStuff
    });
}

methodTwo() {
    return this.ready.then(d => {
        // doOtherStuff
    });
}

基本上我需要做这些事情，只有当我确定服务已经准备好时。 我实际上只需要检查它是否准备好了（methodOne 在做什么，只是用methodTwo 说明，它也很容易做更多的东西）。

我想全力以赴地使用 Observables，但对于这种特殊情况，我发现很难与 Observables 的类似解决方案竞争。

Promises 会记住该值并知道它是否已解决。一个 Observable 稍微复杂一些，创建同样的流程似乎很麻烦。我需要订阅 Observable 的任何内容，以便知道它何时准备就绪。有时该方法被提前调用 - 在 Observable 发射之前，有时在 Observable 已经发射之后调用。

我现在有这个，但它似乎不起作用：

this.ready$ = someObservable // Will fire after a litle while but never finish - i only need the first to check though.
  .publishReplay(1).refCount(); // Trying to replay if subscription comes after emit.

this.ready$.subscribe(_ => {
    // This will be called
});

methodOne() { 
    this.ready$.subscribe(_ => {
        // Not called
    });
};

也许我误解了publishReplay 和refCount 的用法？

Answer 1

我认为您正在寻找的是AsyncSubject。它很好地模仿了 promise 的行为。这是描述：

AsyncSubject 是一个变体，其中只有最后一个值 可观察的执行被发送给它的观察者，并且只有当 执行完成。

在您的情况下如何使用它：

subject = new AsyncSubject();
ready = streamOfData(stuff).first().subscribe(subject);    
methodOne() {
    return this.subject.asObservable();
}

主题订阅 first 操作符返回的底层 observable 并等待它完成。它收集所有订阅者，但不向他们发送任何值。一旦底层的 observable 完成，它就会记住该值并将其发送给收集的订阅者。所有新的未来订阅者都将立即传递这个存储的解析值。

这是一个简单的例子，展示了你可以在 observable 完成之前或之后订阅：

const subject = new AsyncSubject();
const o = subject.asObservable();
o.subscribe((v) => {
  console.log(v);
});
interval(500).first().subscribe(subject);

setTimeout(() => {
  o.subscribe((v) => {
    console.log(v);
  });
}, 2000);