javascript - Observable 与 Subject 和 asObservable

Question

我正在学习 RxJs，我正在寻求对我的假设的确认或纠正。

我正在尝试在我可以在我的服务类的不同位置使用 .next() 的服务中使一个公共(public)只读可见。我想知道这是否是正确的方法:

private myObservable = new Subject<T>();
public myObservable$: Observable<T> = this.myObservable.asObservable();

• 用户可以订阅myObservable$
• 我可以使用myObservable.next(...);

它工作得很好，但我有足够的经验知道我可能只是一个不知情的白痴(RxJS 是巨大的)。对于所述用例，这是正确的模式和正确的对象吗？

Answer 1

你所做的是正确的。然而，还有一个更短的符号。由于 Subject 已经是一个 Observable(它继承了 Observable 类)，您可以将类型检查留给 TypeScript:

private myObservable = new Subject<T>();
public myObservable$: Observable<T> = this.myObservable;

您服务的任何消费者都可以订阅 myObservable$ 但无法调用 myObservable$.next() 因为 TypeScript 不允许您这样做(Observable 类没有任何 next() 方法)。

这实际上是推荐的做法，RxJS 内部从不使用 asObservable 无论如何。有关更详细的讨论，请参阅:

• https://github.com/ReactiveX/rxjs/pull/2408

• https://github.com/ReactiveX/rxjs/issues/2391

看到一个非常相似的问题:Should rxjs subjects be public in the class?