Created
November 17, 2011 06:21
-
-
Save takezoe/1372510 to your computer and use it in GitHub Desktop.
wraps java.io.InputStream by scala.collection.immutable.Stream
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
val stream = fromInputStream(new java.io.FileInputStream("test.jpg"), 8 * 1024) | |
/** | |
* Makes Stream which reads every bytes with specified size from java.io.InputStream. | |
*/ | |
@tailrec | |
def fromInputStream(in: java.io.InputStream, bufferSize: Int): Stream[Array[Byte]] = { | |
val buffer = new Array[Byte](bufferSize) | |
in.read(buffer) match { | |
case -1 => Stream.empty | |
case len => buffer.slice(0, len) #:: fromInputStream(in, bufferSize) | |
} | |
} |
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment
直接FileInputStreamとか読むならある程度のサイズをまとめて読んだほうが圧倒的に速いです。
BufferedInputStreamかましたときは…どうなんでしょう。