-
Notifications
You must be signed in to change notification settings - Fork 7.6k
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
combineLatest(Iterable<Publisher<>>, Function<>) not emitting on empty iterable #5412
Comments
Wrong expectation. If you know you have zero sources, you are using the wrong operator to trigger actions. You can pick |
@akarnokd Well, OK, makes sense. It took me quite a while to track this one down. Do you think it should be included in the docs? I can document it and make pull request |
Yes, something along the line of this:
Note that there are several overloads to be considered in both |
…accepting unspecified number of sources. This commit resolves ReactiveX#5412
…accepting unspecified number of sources. This commit resolves ReactiveX#5412
…accepting unspecified number of sources. This commit resolves ReactiveX#5412
I am using RxJava 2.10 and operator
io.reactivex.Flowable#combineLatest(java.lang.Iterable<? extends org.reactivestreams.Publisher<? extends T>>, io.reactivex.functions.Function<? super java.lang.Object[],? extends R>)
but I've seen this behavior in 1.x as well.
Overload of combineLatests (and combineLatestsDelayError) that takes Iterable of Publishers is not emitting any items and 'combiner' function passed to it is not called when iterable is empty. For this operator I would expect it to scale linearly, that is:
The text was updated successfully, but these errors were encountered: