Closed mcenkar closed 8 years ago
What versions are you using?
v0.26.2, RxJava v1.1.6
This is the Java code reproducing the issue:
Observable<Integer> o = Observable.range(1, 350);
Observable<Publisher<Integer>> p = Observable.just(
RxReactiveStreams.toPublisher(o)).asObservable();
for (int u : p.flatMap(v -> RxReactiveStreams.toObservable(v))
.toBlocking()
.toIterable()) {
System.out.println(u);
}
I'll investigate further.
Thanks for your feedback. This is an issue with RxJavaReactiveStreams and has been fixed in 1.1.1; I just released it and may take some time to show up in maven.
Awesome, thanks!
Hi,
seemingly similar code using org.reactivestreams.Publisher throws MissingBackpressureException while code using scala Observables doesn't. Example:
v0.26.2
Output:
Swapping:
with
seems to solve the problem