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
- final def !=(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
- final def ##: Int
- Definition Classes
- AnyRef → Any
- final def ==(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
- final def asInstanceOf[T0]: T0
- Definition Classes
- Any
- def available(): Int
- Definition Classes
- ReadAheadInputStream → InputStream
- Annotations
- @Override()
- def clone(): AnyRef
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.CloneNotSupportedException]) @IntrinsicCandidate() @native()
- def close(): Unit
- Definition Classes
- ReadAheadInputStream → InputStream → Closeable → AutoCloseable
- Annotations
- @Override()
- final def eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- def equals(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef → Any
- final def getClass(): Class[_ <: AnyRef]
- Definition Classes
- AnyRef → Any
- Annotations
- @IntrinsicCandidate() @native()
- def hashCode(): Int
- Definition Classes
- AnyRef → Any
- Annotations
- @IntrinsicCandidate() @native()
- final def isInstanceOf[T0]: Boolean
- Definition Classes
- Any
- def mark(arg0: Int): Unit
- Definition Classes
- InputStream
- def markSupported(): Boolean
- Definition Classes
- InputStream
- final def ne(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- final def notify(): Unit
- Definition Classes
- AnyRef
- Annotations
- @IntrinsicCandidate() @native()
- final def notifyAll(): Unit
- Definition Classes
- AnyRef
- Annotations
- @IntrinsicCandidate() @native()
- 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])
- final def synchronized[T0](arg0: => T0): T0
- Definition Classes
- AnyRef
- def toString(): String
- Definition Classes
- AnyRef → Any
- def transferTo(arg0: OutputStream): Long
- Definition Classes
- InputStream
- Annotations
- @throws(classOf[java.io.IOException])
- final def wait(arg0: Long, arg1: Int): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException])
- final def wait(arg0: Long): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException]) @native()
- final def wait(): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException])
Deprecated Value Members
- def finalize(): Unit
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.Throwable]) @Deprecated
- Deprecated
(Since version 9)