Closed
Description
[RxJava 2.0.0-RC4]
It seems that bufferSize became maxConcurrency.
I checked the Observable.java source.
public final <U> Observable<U> flatMapIterable(
Function<? super T, ? extends Iterable<? extends U>> mapper, int bufferSize) {
return flatMap(ObservableInternalHelper.flatMapIntoIterable(mapper), false,
bufferSize);
}
public final <R> Observable<R> flatMap(
Function<? super T, ? extends ObservableSource<? extends R>> mapper,
boolean delayErrors,
int maxConcurrency) {
return flatMap(mapper, delayErrors, maxConcurrency, bufferSize());
}
I'm not sure whether the param's name is wrong or the source is wrong.