Read a file using Stream (Scala)

read-a-file-using-stream.scala

import java.io.File
import java.io.FileInputStream

case class Chunk(length: Int, bytes: Array[Byte])

def fileContentStream(fileIn: FileInputStream): Stream[Chunk] = {
  val bytes = Array.fill[Byte](1024)(0)
  val length = fileIn.read(bytes)
  Chunk(length, bytes) #:: fileContentStream(fileIn)
}

def usingFileInput[T](filename: String)(f: (Stream[Chunk]) => T): T = {
  val fileInputStream = new FileInputStream(new File(filename))
  val stream = fileContentStream(fileInputStream) takeWhile { chunk => chunk.length > 0 }
  val result = f(stream)
  fileInputStream.close()
  result
}

val file = new File("/Users/mumoshu/Pictures/512.png")
val fileIn = new FileInputStream(file)

in(fileIn) filter { chunk => chunk._2 > 0 } foreach { chunk => chunk._2 }