-
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
ObserveOn: Unsubscribe of RecursiveScheduler #3002
Comments
Yes, looks odd. I can't really remember why the unsubscription of the worker had to be scheduled. Maybe it had something to do with pitfall no. 2: unsubscribing the downstream: something around subscribe and |
Might be another problem here that the call to |
Was it was because we could end up not emitting an |
I think @akarnokd is right, that Re |
I've probably got my last comment backwards. I was thinking that SafeSubscriber was upstream of observeOn but should be downstream so wouldn't have the effect I stated. |
|
Closing via #3682. |
Need to explore the unsubscribe of
recursiveScheduler
:RxJava/src/main/java/rx/internal/operators/OperatorObserveOn.java
Line 122 in 34dce48
It seems to wrap with
child.add(scheduledUnsubscribe)
and then defeat that withchild.add(recursiveScheduler)
.The text was updated successfully, but these errors were encountered: