A set of Akka Stream sources, sinks and flows that integrates Chronicle Queue into Akka Streams - View it on GitHub