File tree Expand file tree Collapse file tree 3 files changed +8
-8
lines changed Expand file tree Collapse file tree 3 files changed +8
-8
lines changed Original file line number Diff line number Diff line change 3
3
import rx .Observable .Operator ;
4
4
import rx .Observer ;
5
5
import rx .Subscriber ;
6
+ import rx .functions .Action1 ;
7
+ import rx .functions .Func1 ;
6
8
import rx .plugins .DebugNotification ;
7
- import rx .util .functions .Action1 ;
8
- import rx .util .functions .Func1 ;
9
9
10
10
public final class DebugSubscriber <T > extends Subscriber <T > {
11
11
private final Func1 <T , T > onNextHook ;
Original file line number Diff line number Diff line change 5
5
import rx .Observable .Operator ;
6
6
import rx .Subscriber ;
7
7
import rx .Subscription ;
8
+ import rx .functions .Action1 ;
9
+ import rx .functions .Actions ;
10
+ import rx .functions .Func1 ;
11
+ import rx .functions .Functions ;
8
12
import rx .operators .DebugSubscriber ;
9
- import rx .util .functions .Action1 ;
10
- import rx .util .functions .Actions ;
11
- import rx .util .functions .Func1 ;
12
- import rx .util .functions .Functions ;
13
13
14
14
/**
15
15
* Implements hooks into the {@link Observable} chain to emit a detailed account of all the events
Original file line number Diff line number Diff line change 15
15
import rx .Notification ;
16
16
import rx .Observable ;
17
17
import rx .Observer ;
18
+ import rx .functions .Action1 ;
19
+ import rx .functions .Func1 ;
18
20
import rx .plugins .DebugHook ;
19
21
import rx .plugins .DebugNotification ;
20
22
import rx .plugins .PlugReset ;
21
23
import rx .plugins .RxJavaPlugins ;
22
- import rx .util .functions .Action1 ;
23
- import rx .util .functions .Func1 ;
24
24
25
25
public class DebugHookTest {
26
26
@ Before
You can’t perform that action at this time.
0 commit comments