Update the signature of "schedule" methods

Author: zsxwing

language-adaptors/rxjava-scala/src/examples/scala/rx/lang/scala/examples/RxScalaDemo.scala

@@ -805,22 +805,20 @@ class RxScalaDemo extends JUnitSuite {
   @Test def schedulerExample2(): Unit = {
     val latch = new CountDownLatch(1)
     val worker = IOScheduler().createWorker
-    worker.schedule(
-      {
-        println("Hello from Scheduler after 1 second")
-        latch.countDown()
-      }, 1 seconds)
+    worker.schedule(1 seconds) {
+      println("Hello from Scheduler after 1 second")
+      latch.countDown()
+    }
     latch.await(5, TimeUnit.SECONDS)
   }
 
   @Test def schedulerExample3(): Unit = {
     val worker = IOScheduler().createWorker
     var no = 1
-    val subscription = worker.schedulePeriodically(
-      {
-        println(s"Hello(${no}) from Scheduler")
-        no += 1
-      }, initialDelay = 1 seconds, period = 100 millis)
+    val subscription = worker.schedulePeriodically(initialDelay = 1 seconds, period = 100 millis) {
+      println(s"Hello(${no}) from Scheduler")
+      no += 1
+    }
     TimeUnit.SECONDS.sleep(2)
     subscription.unsubscribe()
   }
@@ -831,9 +829,9 @@ class RxScalaDemo extends JUnitSuite {
     def hello: Unit = {
       println(s"Hello(${no}) from Scheduler")
       no += 1
-      worker.schedule(hello, 100 millis)
+      worker.schedule(100 millis)(hello)
     }
-    val subscription = worker.schedule(hello, 1 seconds)
+    val subscription = worker.schedule(1 seconds)(hello)
     TimeUnit.SECONDS.sleep(2)
     subscription.unsubscribe()
   }

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

@@ -69,7 +69,7 @@ trait Worker extends Subscription {
    * @param delay time to wait before executing the action
    * @return a subscription to be able to unsubscribe the action (unschedule it if not executed)
    */
-  def schedule(action: => Unit, delay: Duration): Subscription = {
+  def schedule(delay: Duration)(action: => Unit): Subscription = {
     this.asJavaWorker.schedule(
       new Action0 {
         override def call(): Unit = action
@@ -102,7 +102,7 @@ trait Worker extends Subscription {
    * @param period the time interval to wait each time in between executing the action
    * @return a subscription to be able to unsubscribe the action (unschedule it if not executed)
    */
-  def schedulePeriodically(action: => Unit, initialDelay: Duration, period: Duration): Subscription = {
+  def schedulePeriodically(initialDelay: Duration, period: Duration)(action: => Unit): Subscription = {
     this.asJavaWorker.schedulePeriodically(
       new Action0 {
         override def call(): Unit = action