We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 2f8c508 commit d107ebaCopy full SHA for d107eba
rxjava-core/src/main/java/rx/operators/OperationParallel.java
@@ -46,13 +46,13 @@ public Integer call(T t) {
46
return i.incrementAndGet() % s.degreeOfParallelism();
47
}
48
49
- }).flatMap(new Func1<GroupedObservable<Integer, T>, Observable<R>>() {
+ }).mergeMap(new Func1<GroupedObservable<Integer, T>, Observable<R>>() {
50
51
@Override
52
public Observable<R> call(GroupedObservable<Integer, T> group) {
53
return f.call(group.observeOn(s));
54
55
- }).synchronize();
+ });
56
57
});
58
0 commit comments