-
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
GroupBy fixes as reported in Issue 282 #284
GroupBy fixes as reported in Issue 282 #284
Conversation
RxJava-pull-requests #156 FAILURE |
Not quite sure yet what's causing the test to fail on CloudBees. |
RxJava-pull-requests #160 FAILURE |
That failing test has nothing to do with GroupBy and is not one I've seen issues with before. CloudBees is really harsh on thread-scheduling ... |
ReactiveX#282 Refactored to maintain a single subscription that propagates events to the correct child GroupedObservables.
- support unsubscribing from parent and/or child - The following is now possible: ``` groupBy().take(1).mapMany(group -> group.take(20)) ``` - the subscription on the parent will cause new groups to stop being sent, but it will keep sending events until all previously created groups are unsubscribed from
Need these until we finish work at ReactiveX#204
- I specifically want to be testing with real threads here and not virtual time or a synchronous sequence so am giving it a range of counts that are acceptable
GroupBy fixes as reported in Issue 282
RxJava-pull-requests #162 SUCCESS |
…y-fixes GroupBy fixes as reported in Issue 282
Issue #282