java - 对于 RxJava 中的每个

Question

RxJava 上周工作了。从我的问题来看，Chain of responsibility in RxAndroid

但是，我想使用 RxJava 中的 foreach 函数来循环结果，但它似乎有所不同。我找不到可以使用的方法或者可能是我的方法不对？？？

Task A ( params: integer , response: String[] )

Task B ( params: String , response: long)

Task A -> B

有人知道该怎么做吗？谢谢。

Observable.from(new Integer[] {1,2})
.map(new Func1<Integer, String[]>() {
    @Override
    public String[] call(String s) {
        return  new String[] { "One","Two","Three"};
    }
}).map(new Func1<String, String>() {
    @Override
    public String call(String s) {
        return String.format("Testing:%s",s);
    }
});

我想做那样的事情

Testing:One

Testing:Two

Testing:Three

Testing:One

Testing:Two

Testing:Three

Answer 1

您可以使用 flatMap/flatMapIterable 运算符来执行第二个数组的展平:

Observable.range(1, 2)
.flatMapIterable(v -> Arrays.asList("One", "Two", "Three"))
.map(s -> String.format("Testing:%s", s))
.subscribe(System.out::println)