20
20
import rx .Scheduler ;
21
21
import rx .Subscription ;
22
22
import rx .functions .Action0 ;
23
- import rx .functions .Action1 ;
24
23
import rx .internal .schedulers .ScheduledAction ;
25
- import rx .subscriptions .BooleanSubscription ;
26
24
import rx .subscriptions .CompositeSubscription ;
27
25
import rx .subscriptions .Subscriptions ;
28
26
import android .os .Handler ;
@@ -53,20 +51,20 @@ private static class InnerHandlerThreadScheduler extends Worker {
53
51
54
52
private final Handler handler ;
55
53
56
- private final CompositeSubscription mCompositeSubscription = new CompositeSubscription ();
54
+ private final CompositeSubscription compositeSubscription = new CompositeSubscription ();
57
55
58
56
public InnerHandlerThreadScheduler (Handler handler ) {
59
57
this .handler = handler ;
60
58
}
61
59
62
60
@ Override
63
61
public void unsubscribe () {
64
- mCompositeSubscription .unsubscribe ();
62
+ compositeSubscription .unsubscribe ();
65
63
}
66
64
67
65
@ Override
68
66
public boolean isUnsubscribed () {
69
- return mCompositeSubscription .isUnsubscribed ();
67
+ return compositeSubscription .isUnsubscribed ();
70
68
}
71
69
72
70
@ Override
@@ -78,8 +76,8 @@ public void call() {
78
76
handler .removeCallbacks (scheduledAction );
79
77
}
80
78
}));
81
- scheduledAction .addParent (mCompositeSubscription );
82
- mCompositeSubscription .add (scheduledAction );
79
+ scheduledAction .addParent (compositeSubscription );
80
+ compositeSubscription .add (scheduledAction );
83
81
84
82
handler .postDelayed (scheduledAction , unit .toMillis (delayTime ));
85
83
0 commit comments