fix procedure syntax

xuwei-k · xuwei-k · commit f0afc956c071 · 2018-07-04T22:58:29.000+09:00
procedure syntax is deprecated scala/scala@1d4d901
diff --git a/src/main/scala/gopher/Transputer.scala b/src/main/scala/gopher/Transputer.scala
@@ -194,38 +194,38 @@ trait Transputer
  /**
   * called when transducer is started.
   */
- protected def onStart() { }
+ protected def onStart(): Unit = { }
 
  /**
   * called when transducer is restarted.
   *
   *@param prev - previous (i.e. failed) instance of trnasputer.
   */
- protected def onRestart(prev:Transputer) { }
+ protected def onRestart(prev:Transputer): Unit = { }
 
 
  /**
   * called when transducer is choose to resume durign recovery.
   */
- protected def onResume() { }
+ protected def onResume(): Unit = { }
 
  /**
   * called when failure is escalated.
   **/
- protected def onEscalatedFailure(ex: Throwable) { }
+ protected def onEscalatedFailure(ex: Throwable): Unit = { }
 
  /**
   * called when transputer is stopped.
   */
- protected def onStop() { }
+ protected def onStop(): Unit = { }
 
- private[gopher] def beforeResume() 
+ private[gopher] def beforeResume(): Unit = 
  {
    flowTermination = createFlowTermination()
    onResume();
  }
 
- private[gopher] def beforeRestart(prev: Transputer) 
+ private[gopher] def beforeRestart(prev: Transputer): Unit = 
  {
    if (!(prev eq null)) {
       recoveryStatistics = prev.recoveryStatistics
diff --git a/src/main/scala/gopher/util/Effected.scala b/src/main/scala/gopher/util/Effected.scala
@@ -39,7 +39,7 @@ class MultithreadedEffected[T](initValue:T) extends Effected[T]
    setv(f(v.get))
   }
 
-  override def replace(x:T)
+  override def replace(x:T): Unit =
   {
    setv(x)
   }

Original file line number	Diff line number	Diff line change
`@@ -39,7 +39,7 @@ class MultithreadedEffected[T](initValue:T) extends Effected[T]`
`39`	`39`	`setv(f(v.get))`
`40`	`40`	`}`
`41`	`41`
`42`		`- override def replace(x:T)`
	`42`	`+ override def replace(x:T): Unit =`
`43`	`43`	`{`
`44`	`44`	`setv(x)`
`45`	`45`	`}`