爲什麼不執行爲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類型的表達式，並通過丟棄一個表達式的值，斯卡拉可以將任何表達式爲單位，所以這就是爲什麼它編譯。

這是恕我直言的混淆，我寧願() => Unit參數而不是=> Unit，那麼它會按預期工作。

順便說一句：你是not the first通過這個;-)