Skip to content
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

Merged
merged 6 commits into from Jun 24, 2014
Merged

Variety of Fixes #1380

merged 6 commits into from Jun 24, 2014

Conversation

benjchristensen
Copy link
Member

... found while working on backpressure.

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".
benjchristensen added a commit that referenced this pull request Jun 24, 2014
@benjchristensen benjchristensen merged commit f4b9b5a into ReactiveX:master Jun 24, 2014
@benjchristensen benjchristensen deleted the fixes branch June 24, 2014 03:01
@cloudbees-pull-request-builder

RxJava-pull-requests #1318 SUCCESS
This pull request looks good

@headinthebox
Copy link
Contributor

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));
Copy link
Member

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.

Copy link
Member Author

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.

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
None yet
Projects
None yet
Development

Successfully merging this pull request may close these issues.

None yet

4 participants