1 
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()
4

1 に答える 1

0

publish接続された Observable を作成します。これは標準の Observable とは少し異なりconnect()、接続された Observable が発行を開始するには呼び出す必要があります。こちらのドキュメントを参照してください。

于 2017-01-11T08:13:37.877 に答える