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() |
void |
close() |
int |
read() |
MqttWireMessage |
readMqttWireMessage()
Reads an
MqttWireMessage from the stream. |
mark, markSupported, read, read, reset, skip
public MqttInputStream(ClientState clientState, InputStream in)
public int read() throws IOException
read
in class InputStream
IOException
public int available() throws IOException
available
in class InputStream
IOException
public void close() throws IOException
close
in interface Closeable
close
in interface AutoCloseable
close
in class InputStream
IOException
public MqttWireMessage readMqttWireMessage() throws IOException, MqttException
MqttWireMessage
from the stream.IOException
MqttException
Copyright © 2019 Eclipse Paho. All rights reserved.