订阅可观察对象(作为主题):
Observable(可观察对象)和Subject(主题)是RxJS中两个最常用的对象。订阅可观察对象就是将一个观察者添加到可观察对象序列中,以便在可观察对象发出新值时触发观察者的回调函数。Subject继承自Observable,它不仅可以订阅,还可以用于手动推送新值。
以下是一个订阅Observable和Subject的示例代码:
// 订阅Observable
const observable = new Observable((observer) => {
observer.next('值1');
observer.next('值2');
observer.complete();
});
observable.subscribe({
next: (value) => console.log(value),
complete: () => console.log('完成'),
});
// 订阅Subject
const subject = new Subject();
subject.next('值1');
subject.subscribe({
next: (value) => console.log(value),
});
subject.next('值2');
subject.complete();
/*
输出结果:
值1
值2
完成
值2
*/