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
最佳答案
您可以使用 flatMap
/flatMapIterable
运算符来执行第二个数组的展平:
Observable.range(1, 2)
.flatMapIterable(v -> Arrays.asList("One", "Two", "Three"))
.map(s -> String.format("Testing:%s", s))
.subscribe(System.out::println)
关于java - 对于 RxJava 中的每个,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/35547953/