我正在从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')
});