public class MqttInputStream extends InputStream
MqttInputStream
lets applications read instances of MqttWireMessage
.Constructor and Description |
---|
MqttInputStream(ClientState clientState,
InputStream in) |
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.
|
int |
read()
Reads the next byte of data from the input stream.
|
MqttWireMessage |
readMqttWireMessage()
Reads an
MqttWireMessage from the stream. |
mark, markSupported, read, read, reset, skip
public MqttInputStream(ClientState clientState, InputStream in)
public int available() throws IOException
InputStream
Note that while some implementations of InputStream
will return the total number of bytes
in the stream, many will not. It is never correct to use the return value of this method to
allocate a buffer intended to hold all data in this stream.
A subclass' implementation of this method may choose to throw an IOException
if this
input stream has been closed by invoking the InputStream.close()
method.
The available
method for class InputStream
always returns 0
.
This method should be overridden by subclasses.
available
in class InputStream
0
when it reaches the end of the input stream.IOException
- if an I/O error occurs.public void close() throws IOException
InputStream
The close
method of InputStream
does nothing.
close
in interface Closeable
close
in interface AutoCloseable
close
in class InputStream
IOException
- if an I/O error occurs.public int read() throws IOException
InputStream
int
in the range 0
to 255
. If no byte is available because
the end of the stream has been reached, the value -1
is returned. This method blocks
until input data is available, the end of the stream is detected, or an exception is thrown.
A subclass must provide an implementation of this method.
read
in class InputStream
-1
if the end of the stream is reached.IOException
- if an I/O error occurs.public MqttWireMessage readMqttWireMessage() throws IOException, MqttException
MqttWireMessage
from the stream.IOException
MqttException