なぜRxScalaのdoOnSubscribe関数に与えられた関数を実行しないのですか？

Question

val x: Observable[Int] = Observable.just(1).doOnSubscribe(() => println(s"subscribed")) 
    val y = x.subscribe(t => println(s"got item: $t")) 
    println("all done") 

私はこのコードが

subscribed 
got item: 1 
all done 

を印刷するだろうと思っているだろう。しかし、それは最初の「サブスクライブ」を印刷しません。

Answer 1

doOnSubscribeのシグネチャは次のとおりです。

ある

def doOnSubscribe(onSubscribe: => Unit): Observable[T] 

は、それが名前による引数を取ります。ですから、次のようにそれを使用する必要があります。

Observable.just(1).doOnSubscribe(println(s"subscribed")) 

をすることによって、名前はdoOnSubscribeに渡されたときprintlnが実行されませんが、一度だけdoOnSubscribeがそれを使用することを意味します。

何がdoOnSubscribeに渡したことは0-アリティ機能である、タイプ() => Unitの、すなわち発現、および式の値を破棄することにより、Scalaはユニットに任意の式を変えることができ、それがコンパイル理由です。

これはIMHOです。=> Unitの代わりに() => Unit引数を使用すると、期待通りに動作します。ところで

：あなたはこの;-)