scala - 如何在 RX-Scala 中使用可连接的 Observable 模拟 BehaviorSubject

Question

有没有办法在 rx-scala 中模拟Observable一个BehaviorSubject（但没有接口）？Observer即使其成为具有内存的 Observable，以便它可以有多个订阅，并且在每个新订阅上，它都会产生最后一个发出的值？

Observable.publish()完成了一半的工作，但它不会发出最后一个值。Observable.cache.publish()另一方面，重播所有值 - 我需要类似的东西，但它只重播最后一个发出的值，以处理无限流。

Rx-Java 解决方案也被接受，尽管首选原生 Scala 形式！

score 2 · Accepted Answer

简单地使用现有的BehaviorSubjectScala 实现怎么样？正如您所看到的，它当然可以在中使用0.16.0，而且我肯定0.15.0也包含它。

score 1 · Accepted Answer

1

使用 scala 绑定，使用observable replay 1 refCount.

于 2016-08-11T11:45:37.943 回答

2 回答 2