0

如何从 a 中获取所有历史数据PublishSubject

 val ob = PublishSubject[Int]()
 ob.subscribe(x => println("a: " + x))
 ob.onNext(1)
 ob.subscribe(x => println("b: " + x))
 ob.onNext(2)

它打印:

a: 1
a: 2
b: 2

你可以看到没有b: 1打印。

如果我必须使用PublishSubject(因为我需要从多个地方更新一个 observable),我怎样才能确保以后的订阅者也可以获得所有的历史数据?

4

0 回答 0