File tree 8 files changed +4
-26
lines changed
rxjava-contrib/rxjava-async-util/src/main/java/rx/util/async/operators
rxjava-core/src/test/java/rx
8 files changed +4
-26
lines changed Original file line number Diff line number Diff line change 20
20
21
21
import rx .Observable ;
22
22
import rx .Subscription ;
23
- import rx .util .Exceptions ;
23
+ import rx .exceptions .Exceptions ;
24
24
import rx .util .functions .Action0 ;
25
25
import rx .util .functions .Action1 ;
26
26
Original file line number Diff line number Diff line change 21
21
22
22
import rx .CovarianceTest .HorrorMovie ;
23
23
import rx .CovarianceTest .Movie ;
24
- import rx .operators .OperatorScan ;
25
24
import rx .util .functions .Func2 ;
26
25
27
26
public class ReduceTests {
Original file line number Diff line number Diff line change 23
23
24
24
import org .junit .Test ;
25
25
26
- import rx .util .CompositeException .CompositeExceptionCausalChain ;
27
-
28
- import rx .exceptions .CompositeException ;
29
-
30
26
public class CompositeExceptionTest {
31
27
32
28
private final Throwable ex1 = new Throwable ("Ex1" );
Original file line number Diff line number Diff line change 19
19
20
20
import rx .Observable ;
21
21
import rx .Observer ;
22
- import rx .exceptions .OnErrorNotImplimport rx .util .OnErrorNotImplementedException ;
23
- ementedException ;
24
22
import rx .subjects .PublishSubject ;
25
23
import rx .util .functions .Action1 ;
26
24
Original file line number Diff line number Diff line change 28
28
import java .util .concurrent .atomic .AtomicInteger ;
29
29
import java .util .concurrent .atomic .AtomicReference ;
30
30
31
- import org .junit .Ignore ;
32
31
import org .junit .Test ;
33
32
34
33
import rx .Observable ;
Original file line number Diff line number Diff line change 30
30
import org .mockito .stubbing .Answer ;
31
31
32
32
import rx .Observable ;
33
- import rx .Observable .OnSubscribeFunc ;
34
33
import rx .Observer ;
35
34
import rx .Scheduler ;
36
- import rx .Subscription ;
37
- import rx .schedulers .ImmediateScheduler ;
38
35
import rx .schedulers .Schedulers ;
39
36
import rx .schedulers .TestScheduler ;
40
- import rx .schedulers .TrampolineScheduler ;
41
- import rx .subscriptions .BooleanSubscription ;
42
37
import rx .util .functions .Action0 ;
43
38
import rx .util .functions .Action1 ;
44
39
import rx .util .functions .Func1 ;
Original file line number Diff line number Diff line change 17
17
18
18
import static org .mockito .Matchers .*;
19
19
import static org .mockito .Mockito .*;
20
- import static rx .operators .OperatorScan .*;
21
20
22
21
import org .junit .Before ;
23
22
import org .junit .Test ;
Original file line number Diff line number Diff line change 15
15
*/
16
16
package rx .operators ;
17
17
18
- import static org .junit .Assert .assertFalse ;
19
- import static org .mockito .Matchers .any ;
20
- import static org .mockito .Matchers .isA ;
21
- import static org .mockito .Mockito .doAnswer ;
22
- import static org .mockito .Mockito .inOrder ;
23
- import static org .mockito .Mockito .mock ;
24
- import static org .mockito .Mockito .never ;
25
- import static org .mockito .Mockito .verify ;
18
+ import static org .junit .Assert .*;
19
+ import static org .mockito .Matchers .*;
20
+ import static org .mockito .Mockito .*;
26
21
27
22
import java .util .Arrays ;
28
23
import java .util .concurrent .CountDownLatch ;
38
33
import rx .Observable ;
39
34
import rx .Observable .OnSubscribe ;
40
35
import rx .Observer ;
41
- import rx .Scheduler ;
42
36
import rx .Subscriber ;
43
37
import rx .observers .TestSubscriber ;
44
38
import rx .schedulers .Schedulers ;
45
39
import rx .subjects .PublishSubject ;
46
- import rx .subscriptions .Subscriptions ;
47
- import rx .util .functions .Action0 ;
48
40
import rx .util .functions .Func0 ;
49
41
import rx .util .functions .Func1 ;
50
42
You can’t perform that action at this time.
0 commit comments