File tree Expand file tree Collapse file tree 1 file changed +0
-10
lines changed
rxjava-core/src/test/java/rx/internal/util Expand file tree Collapse file tree 1 file changed +0
-10
lines changed Original file line number Diff line number Diff line change 15
15
*/
16
16
package rx .internal .util ;
17
17
18
- import static org .junit .Assert .assertEquals ;
19
18
import static org .junit .Assert .assertTrue ;
20
19
import static org .junit .Assert .fail ;
21
20
22
21
import java .util .Arrays ;
23
- import java .util .concurrent .CountDownLatch ;
24
- import java .util .concurrent .atomic .AtomicInteger ;
25
22
26
23
import org .junit .Test ;
27
24
28
- import rx .Producer ;
29
- import rx .Scheduler ;
30
- import rx .Subscriber ;
31
25
import rx .exceptions .MissingBackpressureException ;
32
- import rx .functions .Action0 ;
33
26
import rx .observers .TestSubscriber ;
34
- import rx .schedulers .Schedulers ;
35
27
36
28
public abstract class RxRingBufferBase {
37
29
@@ -59,7 +51,6 @@ public void addAndPollFailBackpressure() throws MissingBackpressureException {
59
51
60
52
RxRingBuffer b = createRingBuffer ();
61
53
62
- TestSubscriber <Object > s = new TestSubscriber <Object >();
63
54
try {
64
55
for (int i = 0 ; i < RxRingBuffer .SIZE ; i ++) {
65
56
// System.out.println("Add: " + i);
@@ -82,7 +73,6 @@ public void addAndPollFailBackpressure() throws MissingBackpressureException {
82
73
@ Test
83
74
public void addAndPoll () throws MissingBackpressureException {
84
75
RxRingBuffer b = createRingBuffer ();
85
- TestSubscriber <Object > s = new TestSubscriber <Object >();
86
76
b .onNext ("o" );
87
77
b .onNext ("o" );
88
78
b .poll ();
You can’t perform that action at this time.
0 commit comments