class

LavinMQ::MQTT::SubscriptionTree(T)

Inherits Reference < Object

Constants

HASH = "#".to_slice

MQTT wildcard markers, compared by content against the Bytes tokens.

PLUS = "+".to_slice

Constructors

Instance methods

any?(filter : String) : Bool

Returns wether any subscription matches the given filter

Source
each_entry(topic : String, &block : T, UInt8, String -> _)
Source
each_entry
Source
empty?
Source
inspect

Returns an unambiguous and information-rich string representation of this object, typically intended for developers.

This method should usually not be overridden. It delegates to #inspect(IO) which can be overridden for custom implementations.

Also see #to_s.

Source
size

Total number of subscriptions (session/filter pairs) held in the tree.

Source
subscribe(filter : String, session : T, qos : UInt8)
Source
unsubscribe(filter : String, session : T)
Source