flatmap

    0熱度

    1回答

    我面臨着flatMap運算符的隨機行爲,我無法找到原因。有時它觸發,有時它不... 這是的情況: 用戶可以更改我的應用程序中的語言,所以我有一個行爲子語言(由選擇列表觸發)返回作爲它的提供者可以觀察到的。當有變化時,我會調用(通過flatMap)一個http請求來獲取所選語言的數據。 它看起來像這樣: this.languageProvider.getLang$().flatMap(langCod

    0熱度

    1回答

    這是我的data:RDD[Array[String]]火花。我想統計數據中所有元素長度的總和。例如data:(Array(1,2),Array(1,2,3))。我想得到總和:2 + 3 = 5; 起初,我用:data.flatMap(_).count(), 錯誤: error: missing parameter type for expanded function ((x$1) => data.

    1熱度

    2回答

    我有這個prbolem,我有一個RDD[(String,String, List[String]),我想 「flatmap」 它獲得RDD[(String,String, String)]: 如: val x :RDD[(String,String, List[String]) = RDD[(a,b, list[ "ra", "re", "ri"])] 我希望得到: val result:

    3熱度

    1回答

    練習6.8,Chiusano和Bjarnason,Scala中的函數式編程, 87問一個人如何可能會爲以下特徵實現flatMap(): trait RNG { def nextInt: (Int, RNG) } type Rand[+A] = RNG => (A, RNG) 接聽鍵給出瞭如下解決方案: def flatMap[A,B](f: Rand[A])(g: A => R

    0熱度

    1回答

    this.http.get(validate\uniqueness).subscribe(unique => { console.log(" first subscribe "); if(unique.isValid) { this.http.put(url, data).subscribe(val => { console.log("secon

    4熱度

    2回答

    考慮下面的代碼: urls.stream() .flatMap(url -> fetchDataFromInternet(url).stream()) .filter(...) .findFirst() .get(); 將fetchDataFromInternet堪稱爲第二網址時,第一個是夠嗎? 我嘗試了一個較小的例子,它看起來像按預期工作。即逐個處理數

    -2熱度

    1回答

    RxJava Kotlin平面圖不會從分割字符串中返回分離對象。而是返回列表 val source: Observable<String> = Observable.just("521934/2342/FOXTROT") .flatMap{Observable.fromArray(it.split("/"))} .subscribe{Log.d(TAG, "$it")} 它返回列表: [5

    3熱度

    1回答

    使用方法引用時,我有這樣的代碼在Java中推斷類型: Flowable.just(1,2,3) .flatMap(Flowable::just); 這個代碼在科特林: Flowable.just(1,2,3) .flatMap(Flowable::just) 雖然Java代碼編譯罰款,科特林編譯器說: :「錯誤:(47,30)Kotlin:對於類的一個類型參數Flo

    1熱度

    1回答

    比方說,我有以下對象: public class DaylyData { private Date date; private List<Integer> numersList; // standard getters/setters public Map<Integer, Date> getIntToDate() { Map<Integer, Date> resultMa

    4熱度

    1回答

    我不知道Scala編譯器如何使用flatMap和Option的序列。 如果我對序列的序列使用flatMap: println(Seq(Seq(1), Seq()).flatMap(a => a)) // List(1) 將串連所有嵌套序列,如果我的Option秒的順序使用它 同樣的情況: println(Seq(Some(1), None).flatMap(a => a)) // List(1