java - RxScala ConnectableObservable.doOnSubscribe 从未被调用？

Question

val observable = Observable(...)
    .publish
val subscription = observable.connect

observable.doOnsubscribe(() => doSomething)
    .subscribe()

doSomething 永远不会被调用。 RxJava 的完全相同的代码可以正常工作。似乎出于某种原因它从未传播到底层 Java Observable

更新:所以我的解决方法是

observable.asJavaObservable
    .doOnSubscribe(new Action0 {
        override def call(): Unit = {
            doSomething
        }
    }}.asScala
    .subscribe()

Answer 1

publish 创建一个连接的 Observable。这与标准 Observable 有点不同，您需要调用 connect() 才能让连接的 Observable 开始发出。请参阅文档 here .