RxScala ConnectableObservable.doOnSubscribe никогда не называется?

Question

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

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

doSomething никогда не вызывается. Тот же самый код для RxJava работал правильно. Кажется, по какой причине он никогда не распространяется на основной Java Observable

Update: Так что мой обходной путь является

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

Answer 1

publish создает связное Observable. Это немного отличается от стандартного Observable, и вам нужно позвонить connect(), чтобы подключенный Observable начал излучать. См. Документацию here.