akkatoy.scala

// toying with some abstractions with akka

trait Pipeable[F[_]] {
  def pipe(value: F[_], target: ActorRef)(implicit sender: ActorRef = ActorRef.noSender): Unit
}
object Pipeable extends PipeableImplicits {
  def apply[F[_]](implicit ev: Pipeable[F]): Pipeable[F] = ev
}

sealed trait PipeableImplicits {
  implicit val pipeableFuture: Pipeable[Future] =
    new Pipeable[Future] {
      def pipe(value: Future[_], target: ActorRef)(implicit sender: ActorRef) {
        akka.pattern.pipe(value).to(target, sender)
      }
    }

  implicit val pipeableId: Pipeable[Id] =
    new Pipeable[Id] {
      def pipe(value: Id[_], target: ActorRef)(implicit sender: ActorRef) {
        target.tell(value, sender)
      }
    }
}