Creating a scheduler/timer inside of akka typed actor

Question

I'm trying to create a scheduler in my akka typed just to test it out, like to run every x seconds.

def start(): Behavior[ClientMsg] = Behaviors.setup { ctx =>
    ctx.log.info("start() called")

  ctx.system.scheduler.scheduleAtFixedRate(30.seconds, 5000.millis) { () =>
    ctx.self ! TestMessage(""""this is pretty cool"""")
  }  
}

I am getting an error saying an implicit execution context is not in scope.

Where should I get the execution context from when inside of an typed actor? Also, is this how I should be setting up a scheduler/timer?

johanandren johanandren · Accepted Answer · 2020-04-16T09:24:58

Note that using Behaviors.withTimers { timers => ... } should be preferred over directly using the system scheduler as it handles removing scheduled sends if the actors stops etc.

Creating a scheduler/timer inside of akka typed actor

2 Answers