RxJS主题/可观察问题

Question

我试图将一个角度函数转换为可观察模式，因为它的当前实现与它有一些异步性。为了讨论这个问题，我们举一个简单的例子。

aFunction(x: boolean){
    if(x){
        // ... do something asynchronous based on the value of x
    }
}

可以通过以下方式将其转换为使用可观察对象：

anObservableFunction(x: boolean): Observable<any> {
    const result = new Subject();
    if(x){
        // ... do something asynchronous based on the value of x
        // ... where once the actual value you want to return to 
        // the subscribing functions, you can pass in the 
        // result.next(value);
        // result.complete();
    }
    return result.asObservable();
}

我所面临的问题（据我所知）是针对无法访问内部选择语句的情况。

anObservableFunction(x: boolean): Observable<any> {
    const result = new Subject();
    if(x){
        // ... do something asynchronous based on the value of x
        // ... where once the actual value you want to return to 
        // the subscribing functions, you can pass in the 
        // result.next(value);
        // result.complete();
    } else {
        // here
    }
    return result.asObservable();
}

如果使用常规主题，订阅函数肯定不会得到任何值，因为事件的顺序是：

• 函数被调用
• 主题已创建
• 值已设置
• 调用函数订阅，因此仅在此事件发生后获取值

如果使用了BehaviorSubject或ReplaySubject，它们的初始/构造值将被保留，从而导致不必要地触发订阅事件？

Answer 1

如果值是同步发出的，则使用主题会有问题，这是正确的。BehaviorSubject的缺点是有一个不必要的初始值，但是ReplaySubject实际上没有这个值，并且可以工作，但是如果以后有人订阅了您可能不想要的方式，它也会重播这个值。

一个简单的技巧是将同步发射延迟一个滴答声：

setTimeout(() => result$.next(42), 0);

但是，您也可以直接返回可观察对象，并避免使用主题：

foo(x) {
  if(x) {
    return callRemoteEndpoint();
  }

  return of(42);
}