A stream processing library for Scala