A scalaz-stream combinator library for Akka Persistence and Apache Camel