为什么在这种情况下下一个函数不发送信息?



我正在从RXJS学习Subject,我不明白为什么在这种情况下next((函数不发送信息:

import {Subject, from} from 'rxjs';
const subject = new Subject<any>();
subject.subscribe({
next: (v) => console.log(`observerA: ${v}`),
});
subject.subscribe({
next: (v) => console.log(`observerB: ${v}`),
});
const observable = from([1, 2, 3]);
observable.subscribe(subject);
subject.next(4) // not working

如果您使用complete进行更新,那么当您直接传递subject进行订阅时,您会看到它自动完成。

subject.subscribe({
next: (v) => console.log(`observerA: ${v}`),
error: (error) => console.log(error),
complete: () => console.log('completed') 
});

最新更新