Skip to content

Instantly share code, notes, and snippets.

View jasongoodwin's full-sized avatar

Jason Goodwin jasongoodwin

View GitHub Profile
@jasongoodwin
jasongoodwin / gist:6276969
Last active March 16, 2017 08:15
Async Akka timeout/retry
package io.pressur
import akka.actor.{ActorRef, Actor}
import akka.pattern.ask
import scala.concurrent.duration._
import scala.concurrent.Future
import akka.pattern.after
import akka.actor.Status._
case class AskWithTimeout[T](actor: ActorRef, message: T)