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 2323import java .util .concurrent .*;
2424import java .util .concurrent .atomic .AtomicInteger ;
2525import java .util .concurrent .atomic .AtomicLong ;
26- import java .util .stream .Collectors ;
27- import java .util .stream .IntStream ;
2826
2927import io .reactivex .rxjava3 .observables .ConnectableObservable ;
30- import io .reactivex .rxjava3 .subjects .CompletableSubject ;
31- import org .junit .Assert ;
3228import org .junit .Test ;
3329
3430import io .reactivex .rxjava3 .core .*;
@@ -408,7 +404,7 @@ public void accept(byte[] v) throws Exception {
408404 System .out .printf ("Bounded Replay Leak check: After: %.3f MB%n" , after .get () / 1024.0 / 1024.0 );
409405
410406 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 )
412408 + " -> " + after .get () / 1024.0 / 1024.0 );
413409 }
414410 }
You can’t perform that action at this time.
0 commit comments