Safe direct-style streaming, concurrency and resiliency for Scala on the JVM - View it on GitHub