订阅另一个可观察对象中的嵌套可观察对象
Subscribing to a nested observable inside another observable
我有一个行为主题,它包含一些数据的可观察值。
即
BehaviorSubject<Observable<data>>
如何直接订阅嵌套的 observable?
您应该将其通过管道传输到 the flattening operators 之一,例如 mergeMap
:
yourSubject.pipe(mergeMap(v => v))
我的例子:
const t = timer(0, 500).pipe(take(5));
const s = new BehaviorSubject(t);
s.next(t);
s.pipe(mergeMap(v => v)).subscribe(console.log);
s.next(t);
s.next(t);
我有一个行为主题,它包含一些数据的可观察值。 即
BehaviorSubject<Observable<data>>
如何直接订阅嵌套的 observable?
您应该将其通过管道传输到 the flattening operators 之一,例如 mergeMap
:
yourSubject.pipe(mergeMap(v => v))
我的例子:
const t = timer(0, 500).pipe(take(5));
const s = new BehaviorSubject(t);
s.next(t);
s.pipe(mergeMap(v => v)).subscribe(console.log);
s.next(t);
s.next(t);