File tree Expand file tree Collapse file tree 1 file changed +1
-5
lines changed
src/test/java/io/reactivex/rxjava3/internal/operators/observable Expand file tree Collapse file tree 1 file changed +1
-5
lines changed Original file line number Diff line number Diff line change 23
23
import java .util .concurrent .*;
24
24
import java .util .concurrent .atomic .AtomicInteger ;
25
25
import java .util .concurrent .atomic .AtomicLong ;
26
- import java .util .stream .Collectors ;
27
- import java .util .stream .IntStream ;
28
26
29
27
import io .reactivex .rxjava3 .observables .ConnectableObservable ;
30
- import io .reactivex .rxjava3 .subjects .CompletableSubject ;
31
- import org .junit .Assert ;
32
28
import org .junit .Test ;
33
29
34
30
import io .reactivex .rxjava3 .core .*;
@@ -408,7 +404,7 @@ public void accept(byte[] v) throws Exception {
408
404
System .out .printf ("Bounded Replay Leak check: After: %.3f MB%n" , after .get () / 1024.0 / 1024.0 );
409
405
410
406
if (initial + 100 * 1024 * 1024 < after .get ()) {
411
- Assert . fail ("Bounded Replay Leak check: Memory leak detected: " + (initial / 1024.0 / 1024.0 )
407
+ fail ("Bounded Replay Leak check: Memory leak detected: " + (initial / 1024.0 / 1024.0 )
412
408
+ " -> " + after .get () / 1024.0 / 1024.0 );
413
409
}
414
410
}
You can’t perform that action at this time.
0 commit comments