A library for treating stream and non-stream transformations uniformly when processing data with Akka Streams