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