Skip to content

Commit

Permalink
2.x: fix warnings
Browse files Browse the repository at this point in the history
  • Loading branch information
akarnokd committed Oct 19, 2016
1 parent edd8aed commit 9e18df6
Show file tree
Hide file tree
Showing 4 changed files with 2 additions and 5 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -38,6 +38,7 @@ protected void subscribeActual(Subscriber<? super T> s) {

static final class BackpressureErrorSubscriber<T>
extends AtomicLong implements Subscriber<T>, Subscription {
private static final long serialVersionUID = -3176480756392482682L;

final Subscriber<? super T> actual;
Subscription s;
Expand Down
2 changes: 0 additions & 2 deletions src/test/java/io/reactivex/TransformerTest.java
Original file line number Diff line number Diff line change
Expand Up @@ -15,8 +15,6 @@

import static org.junit.Assert.*;

import java.io.IOException;

import org.junit.Test;
import org.reactivestreams.Publisher;

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -13,8 +13,6 @@

package io.reactivex.internal.operators.flowable;

import static org.junit.Assert.*;

import org.junit.*;
import org.reactivestreams.*;

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -52,7 +52,7 @@ public void toFlowableLatest() {

@Test
public void toFlowableError1() {
TestSubscriber<Integer> ts = Observable.range(1, 5)
Observable.range(1, 5)
.toFlowable(BackpressureStrategy.ERROR)
.test(1)
.assertFailure(MissingBackpressureException.class, 1);
Expand Down

0 comments on commit 9e18df6

Please sign in to comment.