如何用可在RX-Scala中观察到的可连接性来模拟BehaviorSubject

Question

在rx中，有什么方法可以使Observable模拟BehaviorSubject (但没有，Observer接口)？也就是说，用内存来观察它，这样它就可以有多个订阅，并且在每个新的订阅上，它会产生最后一个发出的值？

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

Rx解决方案也被接受，尽管首选本机Scala表单！

Answer 1

对于scala绑定，使用observable replay 1 refCount。

Answer 2

简单地使用 Scala implementation怎么样？正如您所看到的，它当然可以在0.16.0中使用，我确信0.15.0也包括它。