Java8：使用RxJava将映射到

Question

我知道如何变换Map

但是我想学习如何使用RxJava实现它。

更具体地说：

//Input: 
Map<String,String> in; // map from key to a string number, for example: "10"

//transform: in -> out

//Output:
Map<String,Integer> out; //map from the same key to Integer.parseInt(val) (invariant: val is a string number)




Answer 1

您可以使用Observable。toMap。

我认为这是一个最小的例子：

Map<String, String> test = new HashMap<String, String>() {

    {
        put("1", "1");
        put("2", "2");
    }
};
Map<String, Integer> res = Observable.from(test.entrySet()).toMap(e -> e.getKey(), e -> Integer.parseInt(e.getValue())).toBlocking().first();

Answer 2

我认为Dávid Karnok在某种意义上是正确的，如果你的唯一目标是转换一个地图，那么RxJava并不是特别有用。如果你有（多个）地图的可观察性，这可能更有意义。

然后我建议使用方便的番石榴变压器：https://google.github.io/guava/releases/snapshot/api/docs/com/google/common/collect/Maps.html#transformValues（java.util.Map、com.google.common.base.Function）

Map<String,String> source1 = ...
Map<String,String> source2 = ...

Observable.just(source1, source2)
    .map(map->Maps.transformValues(map, v->Integer.parseInt(v)));

Guava的map value transformer的一个优点是，它不会重新创建地图数据结构，而是创建一个转换视图，该视图可以懒洋洋地（动态地）映射值。

如果您不想依赖番石榴，您可以简单地实现Func1