Driving Spark stream with Scalaz-Stream