2.x: fix ReplayProcessor backpressure and NotificationLite emission b…

…ug (#5493) * 2.x: fix ReplayProcessor backpressure and NotificationLite emission bug * Restore coverage
ReactiveX · Jul 18, 2017 · 81fe956 · 81fe956
1 parent 340bed9
commit 81fe956
Show file tree

Hide file tree

Showing 3 changed files with 501 additions and 308 deletions.
diff --git a/src/main/java/io/reactivex/internal/operators/flowable/FlowableTimeoutTimed.java b/src/main/java/io/reactivex/internal/operators/flowable/FlowableTimeoutTimed.java
@@ -14,14 +14,12 @@
 package io.reactivex.internal.operators.flowable;
 
 import java.util.concurrent.*;
-import java.util.concurrent.atomic.AtomicReference;
 
 import org.reactivestreams.*;
 
 import io.reactivex.*;
 import io.reactivex.Scheduler.Worker;
 import io.reactivex.disposables.Disposable;
-import io.reactivex.internal.disposables.DisposableHelper;
 import io.reactivex.internal.subscribers.FullArbiterSubscriber;
 import io.reactivex.internal.subscriptions.*;
 import io.reactivex.plugins.RxJavaPlugins;