A concurrent programming library written in Scala that combines streaming and monadic I/O