org.eclipse.paho.client.mqttv3.internal.wire
Class MqttInputStream

java.lang.Object
  extended by java.io.InputStream
      extended by org.eclipse.paho.client.mqttv3.internal.wire.MqttInputStream
All Implemented Interfaces:
Closeable

public class MqttInputStream
extends InputStream

An MqttInputStream lets applications read instances of MqttWireMessage.


Constructor Summary
MqttInputStream(InputStream in)
           
 
Method Summary
 int available()
           
 void close()
           
 int read()
           
 MqttWireMessage readMqttWireMessage()
          Reads an MqttWireMessage from the stream.
 
Methods inherited from class java.io.InputStream
mark, markSupported, read, read, reset, skip
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

MqttInputStream

public MqttInputStream(InputStream in)
Method Detail

read

public int read()
         throws IOException
Specified by:
read in class InputStream
Throws:
IOException

available

public int available()
              throws IOException
Overrides:
available in class InputStream
Throws:
IOException

close

public void close()
           throws IOException
Specified by:
close in interface Closeable
Overrides:
close in class InputStream
Throws:
IOException

readMqttWireMessage

public MqttWireMessage readMqttWireMessage()
                                    throws IOException,
                                           MqttException
Reads an MqttWireMessage from the stream.

Throws:
IOException
MqttException


Copyright © 2013. All Rights Reserved.