MqttSubscribeMessage.fromByteBuffer constructor

MqttSubscribeMessage.fromByteBuffer(
  1. MqttHeader header,
  2. MqttByteBuffer messageStream
)

Initializes a new instance of the MqttSubscribeMessage class.

Implementation

MqttSubscribeMessage.fromByteBuffer(
  MqttHeader header,
  MqttByteBuffer messageStream,
) {
  this.header = header;
  this.header!.qos = MqttQos.atLeastOnce;
  readFrom(messageStream);
}