將RxJava Observable轉換爲RxScala Observable

Question

我在Scala中編寫了一個小型的JavaFx應用程序，我喜歡使用RxScala和RxJavaFx。用下面的代碼，我收到了RxJavaObservable：

JavaFxObservable.fromObservableValue(textfield.textProperty()) 

顯然，正如我在斯卡拉寫，我想有一個RxScalaObservable來代替。現在我找到了this post，說我要麼直接導入隱式轉換類JavaConversions._，要麼直接調用toScalaObservable。然而，第一個選項，我和第二個選項不這樣做看起來有點醜：

選項1：

import rx.lang.scala.JavaConversions._ 
JavaFxObservable.fromObservableValue(textfield.textProperty()) 
    .map(s => /* do something */) 

這不起作用，因爲RxJava提供map操作員好吧，儘管論證的類型在技術上講是不同的。

選項2：

import rx.lang.scala.JavaConversions._ 
toScalaObservable(JavaFxObservable.fromObservableValue(textfield.textProperty())) 
    .map(s => /* do something */) 

這工作，但說實話的人，這看起來真的很可怕！

問題1：我是否錯過了一些東西，或者這些確實是唯一的兩個選擇嗎？

我的意思是，要從Java的標準集合轉換爲Scala的集合（反之亦然），您有兩個選項：JavaConverters和JavaConversions。前者引入了一個關鍵字asJava/asScala，而後者則相當於rx.lang.scala.JavaConversions，併爲您隱式轉換（如果您幸運的話！）。谷歌搜索這兩個偏好，很顯然，大多數人更喜歡JavaConverters與asScala關鍵字更明確的隱式轉換。

問題2：有沒有類似的結構像JavaConverters與RxScala？這將使上面這麼多清潔的代碼，我會說：

import rx.lang.scala.JavaConverters._ // this class doesn't exist! 
JavaFxObservable.fromObservableValue(textfield.textProperty()) 
    .asScala 
    .map(s => /* do something */) 

Answer 1

這個問題是RxScala項目this pull request的出發點。

原始問題中提出的語法可以通過導入rx.lang.scala.JavaConverters來使用。

import rx.lang.scala.JavaConverters._ 
JavaFxObservable.fromObservableValue(textfield.textProperty()) 
    .asScala 
    .map(s => /* do something */) 

同樣Scala的Observable可以轉化成使用asJava一個Java Observable。

另請參閱預期用途的examples。

Answer 2

我會寫你的例子如下：

import rx.lang.scala.JavaConversions._ 
val texts: Observable[String] = JavaFxObservable.fromObservableValue(textfield.textProperty()) 
texts.map(s => /* do something */) 

其中Observable[String]是Scala的觀測。 給予一個明確的類型爲VAL texts確保英寸

爲什麼沒有asScala隱式轉換踢？

這就需要另一個隱含的包裝類（讓我們在PreScalaObservable調用），只叫toScala一個方法，所以，當你會寫myJavaObservable.toScala，編譯器會變成類似toPreScalaObservable(myJavaObservable).toScala。

有兩個包裝類會有點混亂。或者如果你非常聰明，你實際上可以將asScala方法放到Scala Observable中，並像返回this一樣實現它，並且由於Java Observable沒有方法叫做asScala，所以myJavaObservable.toScala可以工作。但是，對於初學者來說，這可能相當複雜......

但是，如果您有更好的主意，或者知道如何簡單介紹這一點，我鼓勵您在RxScala issues中打開一個問題;該項目仍然在0.x，沒有什麼是石頭...... ;-)

Answer 3

爲什麼你需要將窗體RXJava轉換爲RXScala ?, RXScala具有RXJava所具有的所有功能。 例如

ZIP：

@Test def zip(): Unit = { 
    addHeader("Observable zip") 
    Observable.just("hello") 
     .zip(Observable.just(" scala")) 
     .zip(Observable.just(" world!")) 
     .map(s => s._1._1.concat(s._1._2).concat(s._2).toUpperCase) 
     .subscribe(s => println(s)); 
    } 

MERGE：

@Test def merge(): Unit = { 
    addHeader("Observable merge") 
    Observable.just("hello") 
     .merge(Observable.just(" scala")) 
     .merge(Observable.just(" world!")) 
     .reduce((s, s1) => s.concat(s1)) 
     .map(s => s.toUpperCase).subscribe(s => println(s)) 
    } 

FLATMAP：

@Test def flatMap(): Unit = { 
    addHeader("Flat Map") 
    val text = "number mutated in flatMap::" 
    val list = getList 
    Observable.from(list) 
     .flatMap(n => Observable.just(n) //--> New pipeline 
     .map(n => text.concat(String.valueOf(n)))) 
     .map(s => s.toUpperCase()) 
     .subscribe(s => println(s)) 
    } 

我會從頭開始跟你說實話。 如果你想看看更多的操作示例https://github.com/politrons/reactiveScala