Type Members

1.  final case class BadConnectMessage(clientId: Either[DecodeError, String], willTopic: Option[Either[DecodeError, String]], willMessage: Option[Either[DecodeError, String]], username: Option[Either[DecodeError, String]], password: Option[Either[DecodeError, String]]) extends DecodeError with Product with Serializable

   Something is wrong with the connect message

2.  final case class BadPublishMessage(topicName: Either[DecodeError, String], packetId: Option[PacketId], payload: ByteString) extends DecodeError with Product with Serializable

   Something is wrong with the publish message

3.  final case class BadSubscribeMessage(packetId: PacketId, topicFilters: Seq[(Either[DecodeError, String], ControlPacketFlags)]) extends DecodeError with Product with Serializable

   Something is wrong with the subscribe message

4.  final case class BadUnsubscribeMessage(packetId: PacketId, topicFilters: Seq[Either[DecodeError, String]]) extends DecodeError with Product with Serializable

   Something is wrong with the unsubscribe message

5.  sealed abstract class DecodeError extends AnyRef

   Returned by decoding when no decoding can be performed

6.  final case class DecodeErrorOrControlPacket(v: Either[DecodeError, ControlPacket]) extends Product with Serializable

   JAVA API

7.  final case class InvalidPacketSize(packetSize: Int, maxPacketSize: Int) extends DecodeError with Product with Serializable

   A message has been received that exceeds the maximum we have chosen--which is typically much less than what the spec permits.

   A message has been received that exceeds the maximum we have chosen--which is typically much less than what the spec permits. The reported sizes do not include the fixed header size of 2 bytes.

8.  implicit final class MqttByteIterator extends AnyVal
9.  implicit final class MqttConnAck extends AnyVal
10.  implicit final class MqttConnect extends AnyVal
11.  implicit final class MqttControlPacket extends AnyVal
12.  implicit final class MqttDisconnect extends AnyVal
13.  implicit final class MqttPingReq extends AnyVal
14.  implicit final class MqttPingResp extends AnyVal
15.  implicit final class MqttPubAck extends AnyVal
16.  implicit final class MqttPubComp extends AnyVal
17.  implicit final class MqttPubRec extends AnyVal
18.  implicit final class MqttPubRel extends AnyVal
19.  implicit final class MqttPublish extends AnyVal
20.  implicit final class MqttRemainingLength extends AnyVal
21.  implicit final class MqttString extends AnyVal
22.  implicit final class MqttSubAck extends AnyVal
23.  implicit final class MqttSubscribe extends AnyVal
24.  implicit final class MqttUnsubAck extends AnyVal
25.  implicit final class MqttUnsubscribe extends AnyVal
26.  final case class UnknownConnectProtocol(protocolName: Either[DecodeError, String], protocolLevel: ProtocolLevel) extends DecodeError with Product with Serializable

    Cannot determine the protocol name/level combination of the connect

27.  final case class UnknownPacketType(packetType: ControlPacketType, flags: ControlPacketFlags) extends DecodeError with Product with Serializable

    Cannot determine the type/flags combination of the control packet