flatmap

0热度

1回答

我面临着flatMap运算符的随机行为，我无法找到原因。有时它触发，有时它不... 这是的情况：用户可以更改我的应用程序中的语言，所以我有一个行为子语言（由选择列表触发）返回作为它的提供者可以观察到的。当有变化时，我会调用（通过flatMap）一个http请求来获取所选语言的数据。它看起来像这样： this.languageProvider.getLang$().flatMap(langCod

0热度

1回答

火花使用下划线作为参数RDD.flatmap或地图

这是我的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回答

Flatmap阶[字符串，字符串列表[字符串]

我有这个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回答

用于状态转换的flatMap（）的实现

练习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回答

Angular 2 - 链接http请求时避免延迟

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回答

flatMap是否保证懒惰？

考虑下面的代码： urls.stream() .flatMap(url -> fetchDataFromInternet(url).stream()) .filter(...) .findFirst() .get(); 将fetchDataFromInternet堪称为第二网址时，第一个是够吗？我尝试了一个较小的例子，它看起来像按预期工作。即逐个处理数

-2热度

1回答

RxJava Kotlin如何从单个可观察对象中获取分离对象<String>

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回答

为什么在执行flatmap（）调用时会出现编译错误？

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

4热度

1回答

为什么“flatMap”在Scala中使用Option类型的序列？

我不知道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