@@ -45,21 +45,21 @@ public String toString() {
45
45
private static class CompareActionsByTime implements Comparator <TimedAction > {
46
46
@ Override
47
47
public int compare (TimedAction action1 , TimedAction action2 ) {
48
- return Long .valueOf (action1 .time ).compareTo (Long .valueOf (action2 .time ));
48
+ return Long .valueOf (action1 .time ).compareTo (Long .valueOf (action2 .time ));
49
49
}
50
50
}
51
51
52
52
private long time ;
53
53
54
54
@ Override
55
55
public Subscription schedule (Func0 <Subscription > action ) {
56
- return schedule (action , 0L , TimeUnit .NANOSECONDS );
56
+ return schedule (action , 0L , TimeUnit .NANOSECONDS );
57
57
}
58
58
59
59
@ Override
60
60
public Subscription schedule (Func0 <Subscription > action , long dueTime , TimeUnit unit ) {
61
- queue .add (new TimedAction (now () + unit .toNanos (dueTime ), action ));
62
- return Subscriptions .empty ();
61
+ queue .add (new TimedAction (now () + unit .toNanos (dueTime ), action ));
62
+ return Subscriptions .empty ();
63
63
}
64
64
65
65
@ Override
@@ -68,7 +68,7 @@ public long now() {
68
68
}
69
69
70
70
public void advanceTimeBy (long dueTime , TimeUnit unit ) {
71
- advanceTimeTo (time + unit .toNanos (dueTime ), TimeUnit .NANOSECONDS );
71
+ advanceTimeTo (time + unit .toNanos (dueTime ), TimeUnit .NANOSECONDS );
72
72
}
73
73
74
74
public void advanceTimeTo (long dueTime , TimeUnit unit ) {
0 commit comments