demonstration of bridging akka actors to scalaz-streams using queues