|
13 | 13 |
|
14 | 14 | package io.reactivex.internal.operators.observable;
|
15 | 15 |
|
16 |
| -import org.junit.Assert; |
17 |
| -import org.junit.Ignore; |
18 |
| -import org.junit.Test; |
19 |
| -import org.mockito.InOrder; |
| 16 | +import static org.junit.Assert.*; |
| 17 | +import static org.mockito.ArgumentMatchers.*; |
| 18 | +import static org.mockito.Mockito.*; |
20 | 19 |
|
21 |
| -import java.util.ArrayList; |
22 |
| -import java.util.Arrays; |
23 |
| -import java.util.List; |
24 |
| -import java.util.concurrent.CountDownLatch; |
25 |
| -import java.util.concurrent.TimeUnit; |
| 20 | +import java.util.*; |
| 21 | +import java.util.concurrent.*; |
26 | 22 | import java.util.concurrent.atomic.AtomicInteger;
|
27 | 23 |
|
| 24 | +import org.junit.*; |
| 25 | +import org.mockito.InOrder; |
| 26 | + |
| 27 | +import io.reactivex.*; |
28 | 28 | import io.reactivex.Observable;
|
29 |
| -import io.reactivex.ObservableSource; |
30 | 29 | import io.reactivex.Observer;
|
31 | 30 | import io.reactivex.Scheduler.Worker;
|
32 |
| -import io.reactivex.TestHelper; |
33 | 31 | import io.reactivex.annotations.NonNull;
|
34 |
| -import io.reactivex.disposables.Disposable; |
35 |
| -import io.reactivex.disposables.Disposables; |
| 32 | +import io.reactivex.disposables.*; |
36 | 33 | import io.reactivex.exceptions.TestException;
|
37 |
| -import io.reactivex.functions.Action; |
38 |
| -import io.reactivex.functions.Consumer; |
39 |
| -import io.reactivex.functions.Function; |
| 34 | +import io.reactivex.functions.*; |
40 | 35 | import io.reactivex.internal.functions.Functions;
|
41 | 36 | import io.reactivex.internal.fuseable.HasUpstreamObservableSource;
|
42 |
| -import io.reactivex.internal.operators.observable.ObservableReplay.BoundedReplayBuffer; |
43 |
| -import io.reactivex.internal.operators.observable.ObservableReplay.Node; |
44 |
| -import io.reactivex.internal.operators.observable.ObservableReplay.SizeAndTimeBoundReplayBuffer; |
45 |
| -import io.reactivex.internal.operators.observable.ObservableReplay.SizeBoundReplayBuffer; |
| 37 | +import io.reactivex.internal.operators.observable.ObservableReplay.*; |
46 | 38 | import io.reactivex.observables.ConnectableObservable;
|
47 | 39 | import io.reactivex.observers.TestObserver;
|
48 | 40 | import io.reactivex.plugins.RxJavaPlugins;
|
49 |
| -import io.reactivex.schedulers.Schedulers; |
50 |
| -import io.reactivex.schedulers.TestScheduler; |
| 41 | +import io.reactivex.schedulers.*; |
51 | 42 | import io.reactivex.subjects.PublishSubject;
|
52 | 43 |
|
53 |
| -import static org.junit.Assert.assertEquals; |
54 |
| -import static org.junit.Assert.assertSame; |
55 |
| -import static org.junit.Assert.assertTrue; |
56 |
| -import static org.junit.Assert.fail; |
57 |
| -import static org.mockito.ArgumentMatchers.any; |
58 |
| -import static org.mockito.ArgumentMatchers.notNull; |
59 |
| -import static org.mockito.Mockito.inOrder; |
60 |
| -import static org.mockito.Mockito.mock; |
61 |
| -import static org.mockito.Mockito.never; |
62 |
| -import static org.mockito.Mockito.spy; |
63 |
| -import static org.mockito.Mockito.times; |
64 |
| -import static org.mockito.Mockito.verify; |
65 |
| -import static org.mockito.Mockito.verifyNoMoreInteractions; |
66 |
| -import static org.mockito.Mockito.when; |
67 |
| - |
68 | 44 | public class ObservableReplayTest {
|
69 | 45 | @Test
|
70 | 46 | public void testBufferedReplay() {
|
|
0 commit comments