我有一个可观察的,我正试图从中重播主题。它应该发射电流和可观测到的所有以前的事件。
这是我认为会起作用的,根据这个
answer
:
// create an observable from dummy array and a blank replay subject
const observable$ = from([1, 2, 3])
const replay$ = new ReplaySubject()
// create a replay subject from the observable (not working as expected)
observable$.subscribe(replay$)
// log out the events
observable$.subscribe(e => console.log('observable', e) )
replay$.subscribe(e => console.log('replay', e))
原木
observable 1
observable 2
observable 3
replay 1
replay 2
replay 3
我要寻找的行为是这样的,重播主体也会发出以前的事件,比如:
replay [1]
replay [1, 2]
replay [1, 2, 3]
我该怎么办?