public final class NonshareableCountingBufferedDataInputStream
extends java.io.FilterInputStream
implements java.io.DataInput
Constructor and Description |
---|
NonshareableCountingBufferedDataInputStream(java.io.InputStream in)
Creates a
NonshareableCountingBufferedDataInputStream
and saves its argument, the input stream
in , for later use. |
NonshareableCountingBufferedDataInputStream(java.io.InputStream in,
byte[] buf)
Creates a new buffered output stream to write data to the
specified underlying output stream with the specified buffer.
|
NonshareableCountingBufferedDataInputStream(java.io.InputStream in,
int size)
Creates a
NonshareableCountingBufferedDataInputStream
with the specified buffer size,
and saves its argument, the input stream
in , for later use. |
Modifier and Type | Method and Description |
---|---|
int |
available()
Returns an estimate of the number of bytes that can be read (or
skipped over) from this input stream without blocking by the next
invocation of a method for this input stream.
|
void |
close()
Closes this input stream and releases any system resources
associated with the stream.
|
long |
getByteCount()
Get the number of bytes read (or skipped) by this stream.
|
void |
mark(int readlimit)
See the general contract of the
mark
method of InputStream . |
boolean |
markSupported()
Tests if this input stream supports the
mark
and reset methods. |
int |
read()
See
the general contract of the
read
method of InputStream . |
int |
read(byte[] b)
Reads some number of bytes from the contained input stream and
stores them into the buffer array
b . |
int |
read(byte[] b,
int off,
int len)
Reads bytes from this byte-input stream into the specified byte array,
starting at the given offset.
|
boolean |
readBoolean()
See the general contract of the
readBoolean
method of DataInput . |
byte |
readByte()
See the general contract of the
readByte
method of DataInput . |
char |
readChar()
See the general contract of the
readChar
method of DataInput . |
double |
readDouble()
See the general contract of the
readDouble
method of DataInput . |
float |
readFloat()
See the general contract of the
readFloat
method of DataInput . |
void |
readFully(byte[] b)
See the general contract of the
readFully
method of DataInput . |
void |
readFully(byte[] b,
int off,
int len)
See the general contract of the
readFully
method of DataInput . |
int |
readInt()
See the general contract of the
readInt
method of DataInput . |
java.lang.String |
readLine()
See the general contract of the
readLine
method of DataInput . |
long |
readLong()
See the general contract of the
readLong
method of DataInput . |
short |
readShort()
See the general contract of the
readShort
method of DataInput . |
int |
readUnsignedByte()
See the general contract of the
readUnsignedByte
method of DataInput . |
int |
readUnsignedShort()
See the general contract of the
readUnsignedShort
method of DataInput . |
java.lang.String |
readUTF()
See the general contract of the
readUTF
method of DataInput . |
void |
reset()
See the general contract of the
reset
method of InputStream . |
long |
skip(long n)
See the general contract of the
skip
method of InputStream . |
int |
skipBytes(int n)
See the general contract of the
skipBytes
method of DataInput . |
int |
threadSafeAvailable()
Returns an estimate of the number of bytes that can be read (or
skipped over) from this input stream without blocking by the next
invocation of a method for this input stream.
|
public NonshareableCountingBufferedDataInputStream(java.io.InputStream in) throws java.io.IOException
NonshareableCountingBufferedDataInputStream
and saves its argument, the input stream
in
, for later use. An internal
buffer array is created and stored in buf
.in
- the underlying input stream.java.io.IOException
- if underlying stream cannot be read immediatelypublic NonshareableCountingBufferedDataInputStream(java.io.InputStream in, int size) throws java.lang.IllegalArgumentException, java.io.IOException
NonshareableCountingBufferedDataInputStream
with the specified buffer size,
and saves its argument, the input stream
in
, for later use. An internal
buffer array of length size
is created and stored in buf
.in
- the underlying input stream.size
- the buffer size (minimum size 8 bytes).java.lang.IllegalArgumentException
- if size < 8.java.io.IOException
- if underlying stream cannot be read immediatelypublic NonshareableCountingBufferedDataInputStream(java.io.InputStream in, byte[] buf) throws java.lang.IllegalArgumentException, java.io.IOException
in
- the underlying input stream.buf
- the buffer to use (minimum size 8 bytes)java.lang.IllegalArgumentException
- if size < 8.java.io.IOException
- if underlying stream cannot be read immediatelypublic int read() throws java.io.IOException
read
method of InputStream
.read
in class java.io.FilterInputStream
-1
if the end of the
stream is reached.java.io.IOException
- if this input stream has been closed by
invoking its close()
method,
or an I/O error occurs.public int read(byte[] b, int off, int len) throws java.io.IOException
This method implements the general contract of the corresponding
method of
the read
class. As an additional
convenience, it attempts to read as many bytes as possible by repeatedly
invoking the InputStream
read
method of the underlying stream. This
iterated read
continues until one of the following
conditions becomes true:
read
method of the underlying stream returns
-1
, indicating end-of-file, or
available
method of the underlying stream
returns zero, indicating that further input requests would block.
read
on the underlying stream returns
-1
to indicate end-of-file then this method returns
-1
. Otherwise this method returns the number of bytes
actually read.
Subclasses of this class are encouraged, but not required, to attempt to read as many bytes as possible in the same fashion.
read
in class java.io.FilterInputStream
b
- destination buffer.off
- offset at which to start storing bytes.len
- maximum number of bytes to read.-1
if the end of
the stream has been reached.java.io.IOException
- if this input stream has been closed by
invoking its close()
method,
or an I/O error occurs.public long skip(long n) throws java.io.IOException
skip
method of InputStream
.skip
in class java.io.FilterInputStream
java.io.IOException
- if the stream does not support seek,
or if this input stream has been closed by
invoking its close()
method, or an
I/O error occurs.public int available() throws java.io.IOException
This method returns the number of bytes remaining to be read in
the buffer (count - pos
), possibly refilling the buffer
if it was empty at the time of this call. Specifically, it does _not_
try to return the total remaining bytes in the file.
available
in class java.io.FilterInputStream
java.io.IOException
- if this input stream has been closed by
invoking its close()
method,
or an I/O error occurs.public int threadSafeAvailable() throws java.io.IOException
This method returns the number of bytes remaining to be read in
the buffer (count - pos
), or from the wrapped stream
if this stream's buffer was empty at the time of this call. Specifically, it does _not_
try to return the total remaining bytes in the file.
java.io.IOException
- if this input stream has been closed by
invoking its close()
method,
or an I/O error occurs.public void mark(int readlimit)
mark
method of InputStream
.mark
in class java.io.FilterInputStream
readlimit
- the maximum limit of bytes that can be read before
the mark position becomes invalid.reset()
public void reset() throws java.io.IOException
reset
method of InputStream
.
If markpos
is -1
(no mark has been set or the mark has been
invalidated), an IOException
is thrown. Otherwise, pos
is
set equal to markpos
.
public boolean markSupported()
mark
and reset
methods. The markSupported
method of NonshareableCountingBufferedDataInputStream
always returns
false
.markSupported
in class java.io.FilterInputStream
boolean
indicating if this stream type supports
the mark
and reset
methods.InputStream.mark(int)
,
InputStream.reset()
public void close() throws java.io.IOException
close
in interface java.io.Closeable
close
in interface java.lang.AutoCloseable
close
in class java.io.FilterInputStream
java.io.IOException
- if an I/O error occurs.public final int read(byte[] b) throws java.io.IOException
b
. The number of
bytes actually read is returned as an integer. This method blocks
until input data is available, end of file is detected, or an
exception is thrown.
If b
is null, a NullPointerException
is
thrown. If the length of b
is zero, then no bytes are
read and 0
is returned; otherwise, there is an attempt
to read at least one byte. If no byte is available because the
stream is at end of file, the value -1
is returned;
otherwise, at least one byte is read and stored into b
.
The first byte read is stored into element b[0]
, the
next one into b[1]
, and so on. The number of bytes read
is, at most, equal to the length of b
. Let k
be the number of bytes actually read; these bytes will be stored in
elements b[0]
through b[k-1]
, leaving
elements b[k]
through b[b.length-1]
unaffected.
The read(b)
method has the same effect as:
read(b, 0, b.length)
read
in class java.io.FilterInputStream
b
- the buffer into which the data is read.-1
if there is no more data because the end
of the stream has been reached.java.io.IOException
- if the first byte cannot be read for any reason
other than end of file, the stream has been closed and the underlying
input stream does not support reading after close, or another I/O
error occurs.InputStream.read(byte[], int, int)
public final void readFully(byte[] b) throws java.io.IOException
readFully
method of DataInput
.
Bytes for this operation are read from the contained input stream.
readFully
in interface java.io.DataInput
b
- the buffer into which the data is read.java.io.EOFException
- if this input stream reaches the end before
reading all the bytes.java.io.IOException
- the stream has been closed and the contained
input stream does not support reading after close, or
another I/O error occurs.public final void readFully(byte[] b, int off, int len) throws java.io.IOException
readFully
method of DataInput
.
Bytes for this operation are read from the contained input stream.
readFully
in interface java.io.DataInput
b
- the buffer into which the data is read.off
- the start offset of the data.len
- the number of bytes to read.java.io.EOFException
- if this input stream reaches the end before
reading all the bytes.java.io.IOException
- the stream has been closed and the contained
input stream does not support reading after close, or
another I/O error occurs.public final int skipBytes(int n) throws java.io.IOException
skipBytes
method of DataInput
.
Bytes for this operation are read from the contained input stream.
skipBytes
in interface java.io.DataInput
n
- the number of bytes to be skipped.java.io.IOException
- if the contained input stream does not support
seek, or the stream has been closed and
the contained input stream does not support
reading after close, or another I/O error occurs.public final boolean readBoolean() throws java.io.IOException
readBoolean
method of DataInput
.
Bytes for this operation are read from the contained input stream.
readBoolean
in interface java.io.DataInput
boolean
value read.java.io.EOFException
- if this input stream has reached the end.java.io.IOException
- the stream has been closed and the contained
input stream does not support reading after close, or
another I/O error occurs.public final byte readByte() throws java.io.IOException
readByte
method of DataInput
.
Bytes for this operation are read from the contained input stream.
readByte
in interface java.io.DataInput
byte
.java.io.EOFException
- if this input stream has reached the end.java.io.IOException
- the stream has been closed and the contained
input stream does not support reading after close, or
another I/O error occurs.public final int readUnsignedByte() throws java.io.IOException
readUnsignedByte
method of DataInput
.
Bytes for this operation are read from the contained input stream.
readUnsignedByte
in interface java.io.DataInput
java.io.EOFException
- if this input stream has reached the end.java.io.IOException
- the stream has been closed and the contained
input stream does not support reading after close, or
another I/O error occurs.public final short readShort() throws java.io.IOException
readShort
method of DataInput
.
Bytes for this operation are read from the contained input stream.
readShort
in interface java.io.DataInput
java.io.EOFException
- if this input stream reaches the end before
reading two bytes.java.io.IOException
- the stream has been closed and the contained
input stream does not support reading after close, or
another I/O error occurs.public final int readUnsignedShort() throws java.io.IOException
readUnsignedShort
method of DataInput
.
Bytes for this operation are read from the contained input stream.
readUnsignedShort
in interface java.io.DataInput
java.io.EOFException
- if this input stream reaches the end before
reading two bytes.java.io.IOException
- the stream has been closed and the contained
input stream does not support reading after close, or
another I/O error occurs.public final char readChar() throws java.io.IOException
readChar
method of DataInput
.
Bytes for this operation are read from the contained input stream.
readChar
in interface java.io.DataInput
char
.java.io.EOFException
- if this input stream reaches the end before
reading two bytes.java.io.IOException
- the stream has been closed and the contained
input stream does not support reading after close, or
another I/O error occurs.public final int readInt() throws java.io.IOException
readInt
method of DataInput
.
Bytes for this operation are read from the contained input stream.
readInt
in interface java.io.DataInput
int
.java.io.EOFException
- if this input stream reaches the end before
reading four bytes.java.io.IOException
- the stream has been closed and the contained
input stream does not support reading after close, or
another I/O error occurs.public final long readLong() throws java.io.IOException
readLong
method of DataInput
.
Bytes for this operation are read from the contained input stream.
readLong
in interface java.io.DataInput
long
.java.io.EOFException
- if this input stream reaches the end before
reading eight bytes.java.io.IOException
- the stream has been closed and the contained
input stream does not support reading after close, or
another I/O error occurs.public final float readFloat() throws java.io.IOException
readFloat
method of DataInput
.
Bytes for this operation are read from the contained input stream.
readFloat
in interface java.io.DataInput
float
.java.io.EOFException
- if this input stream reaches the end before
reading four bytes.java.io.IOException
- the stream has been closed and the contained
input stream does not support reading after close, or
another I/O error occurs.readInt()
,
Float.intBitsToFloat(int)
public final double readDouble() throws java.io.IOException
readDouble
method of DataInput
.
Bytes for this operation are read from the contained input stream.
readDouble
in interface java.io.DataInput
double
.java.io.EOFException
- if this input stream reaches the end before
reading eight bytes.java.io.IOException
- the stream has been closed and the contained
input stream does not support reading after close, or
another I/O error occurs.readLong()
,
Double.longBitsToDouble(long)
public final java.lang.String readLine() throws java.io.IOException
readLine
method of DataInput
.
Bytes for this operation are read from the contained input stream. Note that this method only supports extended 8-bit ASCII; it does not support UTF-8 or other locale-specific character sets.
readLine
in interface java.io.DataInput
java.io.IOException
- if an I/O error occurs.public final java.lang.String readUTF() throws java.io.IOException
readUTF
method of DataInput
.
Bytes for this operation are read from the contained input stream.
readUTF
in interface java.io.DataInput
java.io.EOFException
- if this input stream reaches the end before
reading all the bytes.java.io.IOException
- the stream has been closed and the contained
input stream does not support reading after close, or
another I/O error occurs.java.io.UTFDataFormatException
- if the bytes do not represent a valid
modified UTF-8 encoding of a string.public long getByteCount()