Advertisement
Guest User

Untitled

a guest
Dec 12th, 2014
163
0
Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
Scala 0.45 KB | None | 0 0
  1.  
  2.     val fileEnumerator: Enumerator[Byte] = {
  3.       println("Start loading data...")
  4.       Enumerator.fromStream(hallOfFameCSV).flatMap(x => Enumerator(x: _*))
  5.     }
  6.  
  7.     val byteToCharEnumeratee:Enumeratee[Byte, Char] = Enumeratee.map[Byte]{ s => s.toChar }
  8.  
  9.     val printlnSink = Iteratee.foreach[Char](char => println(char))
  10.  
  11.     val iter = Iteratee.flatten(fileEnumerator |>> byteToCharEnumeratee &>> printlnSink)
  12.  
  13.     val runner = iter.run
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement