-
Notifications
You must be signed in to change notification settings - Fork 3k
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
fix(SafeSubscriber): Propagate disposal to terminal Subscriber #5311
Conversation
Ensure the internal SafeSubscriber is disposed when an Observable is subscribed with a Subscriber or Subscriber-like object. Fixes ReactiveX#2675
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Yeesh. It's odd that we missed that for so long.
Sorry for my tardiness in reviewing this. I'll do it tomorrow. It LGTM, but there is one situation with interop observables I want to look into. |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
LGTM. Checked and there's no relation to the interop business I mentioned in the comment I made.
There are some concerns here around |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Marking as changes requested, just so I don't accidentally merge this until we're sure there are no bad implications with Subjects and "interop Subjects", which have unsubscribe
methods on them.
I think foreign Subjects should be caught by these lines here, and not be wrapped in a Subscriber: rxjs/src/internal/util/toSubscriber.ts Lines 16 to 18 in 5cf26e7
|
Blocking this because of #5472 |
I think this was superseded by #5472. Closing. |
Description:
Ensure the internal SafeSubscriber is disposed when an Observable is subscribed with a Subscriber or Subscriber-like object.
Related issue (if exists):
#2675
❤️