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.
1 parent 4bdfdf8 commit a900541Copy full SHA for a900541
src/test/java/rx/internal/operators/OperatorConcatTest.java
@@ -797,7 +797,7 @@ public void onNext(Integer t) {
797
798
@Test//(timeout = 100000)
799
public void concatMapRangeAsyncLoopIssue2876() {
800
- final long durationSeconds = 10;
+ final long durationSeconds = 2;
801
final long startTime = System.currentTimeMillis();
802
for (int i = 0;; i++) {
803
//only run this for a max of ten seconds
@@ -823,4 +823,5 @@ public Observable<Integer> call(Integer t) {
823
assertEquals((Integer)999, ts.getOnNextEvents().get(999));
824
}
825
826
+
827
0 commit comments