A concurrent programming library combining monadic and streaming I/O in Scala - View it on GitHub