File tree Expand file tree Collapse file tree 1 file changed +7
-7
lines changed
src/test/java/io/reactivex/internal/operators/flowable Expand file tree Collapse file tree 1 file changed +7
-7
lines changed Original file line number Diff line number Diff line change @@ -1948,16 +1948,16 @@ public void run() throws Exception {
1948
1948
}
1949
1949
};
1950
1950
}
1951
-
1951
+
1952
1952
private static final class TestTicker extends Ticker {
1953
- long tick = 0 ;
1953
+ long tick ;
1954
1954
1955
1955
@ Override
1956
1956
public long read () {
1957
1957
return tick ;
1958
1958
}
1959
1959
}
1960
-
1960
+
1961
1961
@ Test
1962
1962
public void testGroupByEvictionCancellationOfSource5933 () {
1963
1963
PublishProcessor <Integer > source = PublishProcessor .create ();
@@ -2022,11 +2022,11 @@ public void run() throws Exception {
2022
2022
source .onNext (1 );
2023
2023
source .onNext (1 );
2024
2024
ts .awaitCount (3 );
2025
-
2025
+
2026
2026
// Advance time far enough to evict the group.
2027
2027
// NOTE -- Comment this line out to make the test "pass".
2028
2028
testTicker .tick = TimeUnit .SECONDS .toNanos (6 );
2029
-
2029
+
2030
2030
// Send more data in the group (triggering eviction and recreation)
2031
2031
source .onNext (1 );
2032
2032
@@ -2042,12 +2042,12 @@ public void run() throws Exception {
2042
2042
assertTrue (list .contains ("Source canceled" ));
2043
2043
assertEquals (Arrays .asList (
2044
2044
"Group completed" , // this is here when eviction occurs
2045
- "Outer group by canceled" ,
2045
+ "Outer group by canceled" ,
2046
2046
"Group canceled" ,
2047
2047
"Source canceled" // This is *not* here when eviction occurs
2048
2048
), list );
2049
2049
}
2050
-
2050
+
2051
2051
@ Test
2052
2052
public void testCancellationOfUpstreamWhenGroupedFlowableCompletes () {
2053
2053
final AtomicBoolean cancelled = new AtomicBoolean ();
You can’t perform that action at this time.
0 commit comments