DecodeBool read and returns the next byte from the reader and converts to bool returns EOF when no byte is available to read.

DecodeByte read and returns the next byte from the reader returns EOF when no byte is available to read.

EncodeBool appends the boo as byte to the buffer.

EncodeByte appends the byte val to the buffer.

NewPIDGenerator the PID generator.

NewTopicMatcher new topic matcher.

SliceIndex returns the index of the element position returns -1 if not found.

ValidatePublishTopic that a topic used for publishing is valid.

ValidateSubscribeTopic Validate that a topic used for subscriptions is valid.

PIDGenerator is 16 bit id generator as specified by the MQTT spec.

TopicMatcher stores the topic and it's subscribers more than one subscriber can be associated with one topic.

Subscriber subscriber interface, when the subscriber is going away Finalize method will be called to do the cleanup.

Subscribers subscriber list.