class ReadAheadInputStream extends InputStream
InputStream
implementation which asynchronously reads ahead from the underlying input
stream when specified amount of data has been read from the current buffer. It does it by
maintaining two buffers - active buffer and read ahead buffer. Active buffer contains data
which should be returned when a read() call is issued. The read ahead buffer is used to
asynchronously read from the underlying input stream and once the current active buffer is
exhausted, we flip the two buffers so that we can start reading from the read ahead buffer
without being blocked in disk I/O.
- Alphabetic
- By Inheritance
- ReadAheadInputStream
- InputStream
- Closeable
- AutoCloseable
- AnyRef
- Any
- Hide All
- Show All
- Public
- Protected
Instance Constructors
- new ReadAheadInputStream(inputStream: InputStream, bufferSizeInBytes: Int)
Value Members
- def available(): Int
- Definition Classes
- ReadAheadInputStream → InputStream
- Annotations
- @Override()
- def close(): Unit
- Definition Classes
- ReadAheadInputStream → InputStream → Closeable → AutoCloseable
- Annotations
- @Override()
- def mark(arg0: Int): Unit
- Definition Classes
- InputStream
- def markSupported(): Boolean
- Definition Classes
- InputStream
- def read(b: Array[Byte], offset: Int, len: Int): Int
- Definition Classes
- ReadAheadInputStream → InputStream
- Annotations
- @Override()
- def read(): Int
- Definition Classes
- ReadAheadInputStream → InputStream
- Annotations
- @Override()
- def read(arg0: Array[Byte]): Int
- Definition Classes
- InputStream
- Annotations
- @throws(classOf[java.io.IOException])
- def readAllBytes(): Array[Byte]
- Definition Classes
- InputStream
- Annotations
- @throws(classOf[java.io.IOException])
- def readNBytes(arg0: Array[Byte], arg1: Int, arg2: Int): Int
- Definition Classes
- InputStream
- Annotations
- @throws(classOf[java.io.IOException])
- def readNBytes(arg0: Int): Array[Byte]
- Definition Classes
- InputStream
- Annotations
- @throws(classOf[java.io.IOException])
- def reset(): Unit
- Definition Classes
- InputStream
- Annotations
- @throws(classOf[java.io.IOException])
- def skip(n: Long): Long
- Definition Classes
- ReadAheadInputStream → InputStream
- Annotations
- @Override()
- def skipNBytes(arg0: Long): Unit
- Definition Classes
- InputStream
- Annotations
- @throws(classOf[java.io.IOException])
- def transferTo(arg0: OutputStream): Long
- Definition Classes
- InputStream
- Annotations
- @throws(classOf[java.io.IOException])