分组观测值的flatMap和flatMap single

Question

我是RxJava的新手，正在尝试理解它。我有以下来源：

Observable<Employee> obs = Observable.just(
    new Employee(101, "Jim", 68_000, 4.2),
    new Employee(123, "Bill", 194_000, 6.7));  

obs.groupBy(e -> e.getRating())
   .flatMapSingle(e -> e.toMultimap(key -> e.getKey(), emp -> emp.getName()))
   .subscribe(System.out::println);

这种方法打印密钥和相关的值。

如果我这样做了：

obs.groupBy(e -> e.getRating())
       .flatMapSingle(e -> e.toList())
       .subscribe(System.out::println);   

它似乎打印与键相关联的值列表。

但是flatMapSingle到底是如何工作的呢？与flatMap有什么不同

Answer 1

从文档中：

Maps each element of the upstream {@code Flowable} into {@link SingleSource}s, subscribes to all of them
     * and merges their {@code onSuccess} values, in no particular order, into a single {@code Flowable} sequence.

它在两种情况下都是以相同的方式工作的。当您的调用

flatMapSingle(e -> { // convert to some value})

将"e“转换为lambda返回的值。在您的例子中，"e“是GroupedFlowable。

在第一种情况下，将所有元素转换为包含条目(键、值)的map，在第二种情况下，将其转换为列表。在这两种情况下，flatMapSingle()方法都以相同的方式工作。

您会得到不同的结果，因为您使用了不同的Function实现，并将其作为参数放到flatMapSingle中。

在本例中看起来像e -> { .... }的Function参数决定了如何处理源发出的元素。