We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
2 parents 26ffe5e + 1aadf04 commit a1aca70Copy full SHA for a1aca70
src/test/java/rx/internal/operators/BlockingOperatorNextTest.java
@@ -296,7 +296,7 @@ public void run() {
296
297
@Test /* (timeout = 8000) */
298
public void testSingleSourceManyIterators() throws InterruptedException {
299
- Observable<Long> o = Observable.interval(10, TimeUnit.MILLISECONDS);
+ Observable<Long> o = Observable.interval(100, TimeUnit.MILLISECONDS);
300
PublishSubject<Void> terminal = PublishSubject.create();
301
BlockingObservable<Long> source = o.takeUntil(terminal).toBlocking();
302
0 commit comments