diff --git a/src/main/java/io/reactivex/internal/operators/flowable/FlowableOnBackpressureError.java b/src/main/java/io/reactivex/internal/operators/flowable/FlowableOnBackpressureError.java index 0e1a59d34f..71ccf99e76 100644 --- a/src/main/java/io/reactivex/internal/operators/flowable/FlowableOnBackpressureError.java +++ b/src/main/java/io/reactivex/internal/operators/flowable/FlowableOnBackpressureError.java @@ -38,6 +38,7 @@ protected void subscribeActual(Subscriber s) { static final class BackpressureErrorSubscriber extends AtomicLong implements Subscriber, Subscription { + private static final long serialVersionUID = -3176480756392482682L; final Subscriber actual; Subscription s; diff --git a/src/test/java/io/reactivex/TransformerTest.java b/src/test/java/io/reactivex/TransformerTest.java index fd5c78cc5e..f76b2cef52 100644 --- a/src/test/java/io/reactivex/TransformerTest.java +++ b/src/test/java/io/reactivex/TransformerTest.java @@ -15,8 +15,6 @@ import static org.junit.Assert.*; -import java.io.IOException; - import org.junit.Test; import org.reactivestreams.Publisher; diff --git a/src/test/java/io/reactivex/internal/operators/flowable/FlowableFromSourceTest.java b/src/test/java/io/reactivex/internal/operators/flowable/FlowableFromSourceTest.java index 52d0574109..0fa58394c1 100644 --- a/src/test/java/io/reactivex/internal/operators/flowable/FlowableFromSourceTest.java +++ b/src/test/java/io/reactivex/internal/operators/flowable/FlowableFromSourceTest.java @@ -13,8 +13,6 @@ package io.reactivex.internal.operators.flowable; -import static org.junit.Assert.*; - import org.junit.*; import org.reactivestreams.*; diff --git a/src/test/java/io/reactivex/internal/operators/observable/ObservableToXTest.java b/src/test/java/io/reactivex/internal/operators/observable/ObservableToXTest.java index 7dcec0f838..18091c969c 100644 --- a/src/test/java/io/reactivex/internal/operators/observable/ObservableToXTest.java +++ b/src/test/java/io/reactivex/internal/operators/observable/ObservableToXTest.java @@ -52,7 +52,7 @@ public void toFlowableLatest() { @Test public void toFlowableError1() { - TestSubscriber ts = Observable.range(1, 5) + Observable.range(1, 5) .toFlowable(BackpressureStrategy.ERROR) .test(1) .assertFailure(MissingBackpressureException.class, 1);