X Tutup
Skip to content
This repository was archived by the owner on Nov 18, 2024. It is now read-only.

Commit 33e1aff

Browse files
FroussiosFroussios
committed
Removed warnings
1 parent d608e8f commit 33e1aff

24 files changed

+104
-146
lines changed

‎tests/java/itrx/chapter1/BehaviorSubjectTest.java‎

Lines changed: 0 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1,7 +1,5 @@
11
package itrx.chapter1;
22

3-
import static org.junit.Assert.*;
4-
53
import java.util.Arrays;
64

75
import org.junit.Test;

‎tests/java/itrx/chapter1/RxContractTest.java‎

Lines changed: 0 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1,7 +1,5 @@
11
package itrx.chapter1;
22

3-
import static org.junit.Assert.*;
4-
53
import java.util.Arrays;
64

75
import org.junit.Test;

‎tests/java/itrx/chapter1/UnsubscribingTests.java‎

Lines changed: 4 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,7 @@
11
package itrx.chapter1;
22

3-
import static org.junit.Assert.*;
3+
import static org.junit.Assert.assertFalse;
4+
import static org.junit.Assert.assertTrue;
45

56
import java.util.Arrays;
67

@@ -46,6 +47,8 @@ public void testIndependentSubscriptions() {
4647
tester2.assertReceivedOnNext(Arrays.asList(0,1,2));
4748
tester1.assertUnsubscribed();
4849
assertFalse(tester2.isUnsubscribed());
50+
51+
subscription2.unsubscribe();
4952
}
5053

5154
@Test

‎tests/java/itrx/chapter2/aggregation/CountTest.java‎

Lines changed: 0 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1,7 +1,5 @@
11
package itrx.chapter2.aggregation;
22

3-
import static org.junit.Assert.*;
4-
53
import java.util.Arrays;
64

75
import org.junit.Test;

‎tests/java/itrx/chapter2/aggregation/FirstTest.java‎

Lines changed: 0 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1,7 +1,5 @@
11
package itrx.chapter2.aggregation;
22

3-
import static org.junit.Assert.*;
4-
53
import java.util.Arrays;
64
import java.util.concurrent.TimeUnit;
75

‎tests/java/itrx/chapter2/aggregation/GroupByTest.java‎

Lines changed: 1 addition & 28 deletions
Original file line numberDiff line numberDiff line change
@@ -1,41 +1,14 @@
11
package itrx.chapter2.aggregation;
22

3-
import static org.junit.Assert.*;
4-
5-
import java.util.*;
3+
import java.util.Arrays;
64

75
import org.junit.Test;
86

97
import rx.Observable;
10-
import rx.Subscriber;
11-
import rx.Subscription;
128
import rx.observers.TestSubscriber;
13-
import rx.schedulers.Schedulers;
14-
import rx.schedulers.TestScheduler;
15-
import rx.subjects.ReplaySubject;
16-
import rx.subjects.Subject;
179

1810
public class GroupByTest {
1911

20-
private class PrintSubscriber extends Subscriber<Object>{
21-
private final String name;
22-
public PrintSubscriber(String name) {
23-
this.name = name;
24-
}
25-
@Override
26-
public void onCompleted() {
27-
System.out.println(name + ": Completed");
28-
}
29-
@Override
30-
public void onError(Throwable e) {
31-
System.out.println(name + ": Error: " + e);
32-
}
33-
@Override
34-
public void onNext(Object v) {
35-
System.out.println(name + ": " + v);
36-
}
37-
}
38-
3912
public void exampleGroupBy() {
4013
Observable<String> values = Observable.just(
4114
"first",

‎tests/java/itrx/chapter2/aggregation/LastTest.java‎

Lines changed: 0 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -1,9 +1,6 @@
11
package itrx.chapter2.aggregation;
22

3-
import static org.junit.Assert.*;
4-
53
import java.util.Arrays;
6-
import java.util.concurrent.TimeUnit;
74

85
import org.junit.Test;
96

‎tests/java/itrx/chapter2/aggregation/ReduceTest.java‎

Lines changed: 0 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -1,18 +1,12 @@
11
package itrx.chapter2.aggregation;
22

3-
import static org.junit.Assert.*;
4-
53
import java.util.Arrays;
6-
import java.util.concurrent.TimeUnit;
74

85
import org.junit.Test;
96

107
import rx.Observable;
118
import rx.Subscriber;
12-
import rx.Subscription;
139
import rx.observers.TestSubscriber;
14-
import rx.schedulers.Schedulers;
15-
import rx.schedulers.TestScheduler;
1610

1711
public class ReduceTest {
1812

‎tests/java/itrx/chapter2/aggregation/ScanTest.java‎

Lines changed: 0 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -1,18 +1,12 @@
11
package itrx.chapter2.aggregation;
22

3-
import static org.junit.Assert.*;
4-
53
import java.util.Arrays;
6-
import java.util.concurrent.TimeUnit;
74

85
import org.junit.Test;
96

107
import rx.Observable;
118
import rx.Subscriber;
12-
import rx.Subscription;
139
import rx.observers.TestSubscriber;
14-
import rx.schedulers.Schedulers;
15-
import rx.schedulers.TestScheduler;
1610
import rx.subjects.ReplaySubject;
1711
import rx.subjects.Subject;
1812

‎tests/java/itrx/chapter2/aggregation/ToCollectionTest.java‎

Lines changed: 0 additions & 9 deletions
Original file line numberDiff line numberDiff line change
@@ -1,22 +1,13 @@
11
package itrx.chapter2.aggregation;
22

3-
import static org.junit.Assert.*;
4-
53
import java.util.ArrayList;
64
import java.util.Arrays;
75
import java.util.List;
8-
import java.util.concurrent.TimeUnit;
96

107
import org.junit.Test;
118

129
import rx.Observable;
13-
import rx.Subscriber;
14-
import rx.Subscription;
1510
import rx.observers.TestSubscriber;
16-
import rx.schedulers.Schedulers;
17-
import rx.schedulers.TestScheduler;
18-
import rx.subjects.ReplaySubject;
19-
import rx.subjects.Subject;
2011

2112
public class ToCollectionTest {
2213

0 commit comments

Comments
 (0)
X Tutup