Skip to content

Commit df7bf90

Browse files
GroupBy Test Improvement
ObserveOn was the wrong mechanism for delaying behavior as it was relying on the buffering of observeOn. Now using delay() to delay the group since observeOn no longer buffers.
1 parent ac83ed9 commit df7bf90

File tree

1 file changed

+2
-7
lines changed

1 file changed

+2
-7
lines changed

rxjava-core/src/test/java/rx/operators/OperatorGroupByTest.java

Lines changed: 2 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -484,21 +484,16 @@ public Integer call(Integer i) {
484484
@Override
485485
public Observable<Integer> call(GroupedObservable<Integer, Integer> group) {
486486
if (group.getKey() == 0) {
487-
return group.observeOn(Schedulers.newThread()).map(new Func1<Integer, Integer>() {
487+
return group.delay(100, TimeUnit.MILLISECONDS).map(new Func1<Integer, Integer>() {
488488

489489
@Override
490490
public Integer call(Integer t) {
491-
try {
492-
Thread.sleep(2);
493-
} catch (InterruptedException e) {
494-
e.printStackTrace();
495-
}
496491
return t * 10;
497492
}
498493

499494
});
500495
} else {
501-
return group.observeOn(Schedulers.newThread());
496+
return group;
502497
}
503498
}
504499
})

0 commit comments

Comments
 (0)