MqttServerWs2Connection class

The MQTT server alternative websocket connection class

Inheritance

Constructors

MqttServerWs2Connection(SecurityContext? context, EventBus? eventBus, List<RawSocketOption> socketOptions)
Default constructor
MqttServerWs2Connection.fromConnect(String server, int port, EventBus eventBus, List<RawSocketOption> socketOptions)
Initializes a new instance of the MqttWs2Connection class.

Properties

client ↔ WebSocket?
The socket that maintains the connection to the MQTT broker.
getter/setter pairinherited
clientEventBus ↔ EventBus?
The event bus
getter/setter pairinherited
context ↔ SecurityContext?
The security context for secure usage
getter/setter pair
hashCode → int
The hash code for this object.
no setterinherited
headers ↔ Map<String, dynamic>?
User defined websocket headers
getter/setter pairinherited
listeners ↔ List<StreamSubscription>
The stream controller as returned when clients listen.
getter/setter pairinherited
messageStream ↔ MqttByteBuffer
The read buffer
getter/setter pairinherited
onDisconnected ↔ DisconnectCallback?
Unsolicited disconnection callback
getter/setter pairinherited
protocols ↔ List<String>
The websocket subprotocol list
getter/setter pairinherited
readWrapper ↔ ReadWrapper?
The read wrapper
getter/setter pairinherited
runtimeType → Type
A representation of the runtime type of the object.
no setterinherited
socketOptions ↔ List<RawSocketOption>
Socket options, applicable only to TCP sockets
getter/setter pairinherited

Methods

closeClient() → void
Closes the socket immediately.
inherited
connect(String server, int port) → Future<MqttClientConnectionStatus>
Connect
override
connectAuto(String server, int port) → Future<MqttClientConnectionStatus?>
Connect Auto
override
disconnect({bool auto = false}) → void
User requested or auto disconnect disconnection
inherited
disposeClient() → void
Closes and dispose the socket immediately.
inherited
noSuchMethod(Invocation invocation) → dynamic
Invoked when a nonexistent method or property is accessed.
inherited
onData(dynamic data) → void
OnData listener callback
inherited
onDone() → void
OnDone listener callback
inherited
onError(dynamic error) → void
OnError listener callback
inherited
onListen() → StreamSubscription
Implement stream subscription
inherited
send(MqttByteBuffer message) → void
Sends the message in the stream to the broker.
inherited
stopListening() → void
Stops listening the socket immediately.
inherited
toString() → String
A string representation of this object.
inherited

Operators

operator ==(Object other) → bool
The equality operator.
inherited