raboof/pekko
1
0
Fork 0
Code Issues Pull requests Projects Releases 6 Packages Wiki Activity Actions 10

more conversion to FiniteDuration, plus fix the build, see #2521

Browse source 
- also remove resetReceiveTimeout and change receiveTimeout() to return
  a Duration (which may be Undefined)
- also move akka.actor.{cell -> dungeon}, because that is
  + an adequate name
  + and does not coincide with the lowercase version of a class name
This commit is contained in:
Roland 2012-09-18 18:17:44 +02:00
parent 35b7a9e338
commit 947cea3a8c
17 changed files with 120 additions and 107 deletions
Download patch file Download diff file Expand all files Collapse all files

12
akka-cluster/src/main/scala/akka/cluster/Cluster.scala
View file

@ -109,16 +109,16 @@ class Cluster(val system: ExtendedActorSystem) extends Extension {
new Scheduler with Closeable {
override def close(): Unit = () // we are using system.scheduler, which we are not responsible for closing
override def schedule(initialDelay: FiniteDuration, frequency: FiniteDuration,
override def schedule(initialDelay: FiniteDuration, interval: FiniteDuration,
receiver: ActorRef, message: Any)(implicit executor: ExecutionContext): Cancellable =
systemScheduler.schedule(initialDelay, frequency, receiver, message)
systemScheduler.schedule(initialDelay, interval, receiver, message)
override def schedule(initialDelay: FiniteDuration, frequency: FiniteDuration)(f: ⇒ Unit)(implicit executor: ExecutionContext): Cancellable =
systemScheduler.schedule(initialDelay, frequency)(f)
override def schedule(initialDelay: FiniteDuration, interval: FiniteDuration)(f: ⇒ Unit)(implicit executor: ExecutionContext): Cancellable =
systemScheduler.schedule(initialDelay, interval)(f)
override def schedule(initialDelay: FiniteDuration, frequency: FiniteDuration,
override def schedule(initialDelay: FiniteDuration, interval: FiniteDuration,
runnable: Runnable)(implicit executor: ExecutionContext): Cancellable =
systemScheduler.schedule(initialDelay, frequency, runnable)
systemScheduler.schedule(initialDelay, interval, runnable)
override def scheduleOnce(delay: FiniteDuration,
runnable: Runnable)(implicit executor: ExecutionContext): Cancellable =