Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- val fileEnumerator: Enumerator[Byte] = {
- println("Start loading data...")
- Enumerator.fromStream(hallOfFameCSV).flatMap(x => Enumerator(x: _*))
- }
- val byteToCharEnumeratee:Enumeratee[Byte, Char] = Enumeratee.map[Byte]{ s => s.toChar }
- val printlnSink = Iteratee.foreach[Char](char => println(char))
- val iter = Iteratee.flatten(fileEnumerator |>> byteToCharEnumeratee &>> printlnSink)
- val runner = iter.run
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement