Skip to content

Commit 02ff7f7

Browse files
1 parent fc8ea03 commit 02ff7f7

File tree

1 file changed

+5
-5
lines changed

1 file changed

+5
-5
lines changed

language-adaptors/rxjava-scala/src/main/scala/rx/lang/scala/Scheduler.scala

Lines changed: 5 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -57,7 +57,7 @@ trait Scheduler {
5757
* @param delayTime Time the action is to be delayed before executing.
5858
* @return a subscription to be able to unsubscribe from action.
5959
*/
60-
def schedule(delayTime: Duration)(action: Scheduler => Subscription): Subscription = {
60+
def schedule(delayTime: Duration, action: Scheduler => Subscription): Subscription = {
6161
this.schedule[Integer](0, (s: Scheduler, x: Integer) => action(s), delayTime: Duration): Subscription
6262
}
6363

@@ -86,7 +86,7 @@ trait Scheduler {
8686
* @param period The time interval to wait each time in between executing the action.
8787
* @return A subscription to be able to unsubscribe from action.
8888
*/
89-
def schedule(initialDelay: Duration, period: Duration)(action: Scheduler => Subscription): Subscription = {
89+
def schedule(initialDelay: Duration, period: Duration, action: Scheduler => Subscription): Subscription = {
9090
this.schedulePeriodically[Integer](0, (s: Scheduler, x:Integer) => action(s): Subscription, initialDelay: Duration, period: Duration): Subscription
9191
}
9292

@@ -116,7 +116,7 @@ trait Scheduler {
116116
* @param dueTime Time the action is to be executed. If in the past it will be executed immediately.
117117
* @return a subscription to be able to unsubscribe from action.
118118
*/
119-
def schedule(dueTime: Date)(action: Scheduler => Subscription): Subscription = {
119+
def schedule(dueTime: Date, action: Scheduler => Subscription): Subscription = {
120120
this.schedule(0: Integer, (s: Scheduler, x: Integer) => action(s): Subscription, dueTime: Date): Subscription
121121
}
122122

@@ -152,7 +152,7 @@ trait Scheduler {
152152
* @param action action
153153
* @return a subscription to be able to unsubscribe from action.
154154
*/
155-
def schedule(delayTime: Duration)(action: =>Unit): Subscription = {
155+
def schedule(delayTime: Duration, action: =>Unit): Subscription = {
156156
Subscription(asJavaScheduler.schedule(()=>action, delayTime.length, delayTime.unit))
157157
}
158158

@@ -167,7 +167,7 @@ trait Scheduler {
167167
* The time interval to wait each time in between executing the action.
168168
* @return A subscription to be able to unsubscribe from action.
169169
*/
170-
def schedule(initialDelay: Duration, period: Duration)(action: =>Unit): Subscription = {
170+
def schedule(initialDelay: Duration, period: Duration, action: =>Unit): Subscription = {
171171
Subscription(asJavaScheduler.schedulePeriodically(()=>action, initialDelay.length, initialDelay.unit.convert(period.length, period.unit), initialDelay.unit))
172172
}
173173

0 commit comments

Comments
 (0)