readFrom method

  1. @override
void readFrom(
  1. MqttByteBuffer payloadStream
)
override

Creates a payload from the specified header stream.

Implementation

@override
void readFrom(MqttByteBuffer payloadStream) {
  final messageBytes = header!.messageSize - variableHeader!.length;
  message = payloadStream.read(messageBytes);
  length += messageBytes;
}