Skip to content

1.x: fix sample(Observable) not requesting Long.MAX_VALUE#3653

Merged
akarnokd merged 1 commit intoReactiveX:1.xfrom
akarnokd:SampleUnboundedFix1x
Jan 31, 2016
Merged

1.x: fix sample(Observable) not requesting Long.MAX_VALUE#3653
akarnokd merged 1 commit intoReactiveX:1.xfrom
akarnokd:SampleUnboundedFix1x

Conversation

@akarnokd
Copy link
Member

Reported on the rxjava discussion group.

Sample has to disconnect itself from the Producer chain and request Long.MAX_VALUE instead of whatever the downstream requests.

@akarnokd akarnokd added the Bug label Jan 28, 2016
Copy link
Contributor

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Maybe change to AtomicLong? Took me awhile to get it 💭

@artem-zinnatullin
Copy link
Contributor

👍

1 similar comment
@zsxwing
Copy link
Member

zsxwing commented Jan 31, 2016

👍

akarnokd added a commit that referenced this pull request Jan 31, 2016
1.x: fix sample(Observable) not requesting Long.MAX_VALUE
@akarnokd akarnokd merged commit c5a4902 into ReactiveX:1.x Jan 31, 2016
@akarnokd akarnokd deleted the SampleUnboundedFix1x branch January 31, 2016 10:08
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

Projects

None yet

Development

Successfully merging this pull request may close these issues.

3 participants