-
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
Variety of Fixes #1380
Variety of Fixes #1380
Conversation
A rewrite of TakeUntil that doesn't leak NotificationLite.COMPLETE outside of itself. It causes problems to leak the sentinels as other operators also using NotificationLite get confused.
This could cause an unwanted unsubscribe to be propagate because of the `SafeSubscriber`
Remove the null check and lazy creation, build the queue in the ThreadLocal. Fix bugs about "work in progress".
RxJava-pull-requests #1318 SUCCESS |
Nice catches. |
@@ -150,6 +150,12 @@ public void assertUnsubscribed() { | |||
} | |||
} | |||
|
|||
public void assertNoErrors() { | |||
if (getOnErrorEvents().size() > 0) { | |||
throw new AssertionError("Unexpected onError events: " + getOnErrorEvents().size(), getOnErrorEvents().get(0)); |
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.
public AssertionError(String message, Throwable cause)
is a java7 api.
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.
Well that's just silly ... thanks for the catch.
... found while working on backpressure.