MqttConnectionBase class

The MQTT client connection base class



MqttConnectionBase(EventBus clientEventBus)
Default constructor
MqttConnectionBase.fromConnect(String server, int port, EventBus clientEventBus)
Initializes a new instance of the MqttConnection class.


client ↔ dynamic
The socket that maintains the connection to the MQTT broker.
@protected, read / write
clientEventBus ↔ EventBus
The event bus
@protected, read / write
hashCode → int
The hash code for this object. [...]
read-only, inherited
messageStream MqttByteBuffer
The read buffer
@protected, read / write
onDisconnected DisconnectCallback
Unsolicited disconnection callback
@protected, read / write
readWrapper ReadWrapper
The read wrapper
@protected, read / write
runtimeType → Type
A representation of the runtime type of the object.
read-only, inherited


connect(String server, int port) → Future<void>
Connect, must be overridden in connection classes
connectAuto(String server, int port) → Future<void>
Connect for auto reconnect , must be overridden in connection classes
disconnect({bool auto = false}) → void
User requested or auto disconnect disconnection
noSuchMethod(Invocation invocation) → dynamic
Invoked when a non-existent method or property is accessed. [...]
onDone() → void
OnDone listener callback
onError(dynamic error) → void
OnError listener callback
toString() → String
Returns a string representation of this object.


operator ==(Object other) → bool
The equality operator. [...]