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