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