Skip to content

Commit de6a9d3

Browse files
committed
RefCountAsync: adjusted time values as 1 ms is unreliable
1 parent b359bb9 commit de6a9d3

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

src/test/java/rx/internal/operators/OnSubscribeRefCountTest.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -62,7 +62,7 @@ public void setUp() {
6262
public void testRefCountAsync() {
6363
final AtomicInteger subscribeCount = new AtomicInteger();
6464
final AtomicInteger nextCount = new AtomicInteger();
65-
Observable<Long> r = Observable.timer(0, 1, TimeUnit.MILLISECONDS)
65+
Observable<Long> r = Observable.timer(0, 5, TimeUnit.MILLISECONDS)
6666
.doOnSubscribe(new Action0() {
6767

6868
@Override
@@ -94,7 +94,7 @@ public void call(Long l) {
9494

9595
// give time to emit
9696
try {
97-
Thread.sleep(50);
97+
Thread.sleep(52);
9898
} catch (InterruptedException e) {
9999
}
100100

0 commit comments

Comments
 (0)