send method

void send(
  1. MqttByteBuffer message
)

Sends the message in the stream to the broker.

Implementation

void send(MqttByteBuffer message) {
  final length = message.length;
  final messageBytes = message.read(length);
  client?.add(messageBytes.toList());
}