class MQTT::Subscriptions::WaitpointSubscription

Attributes

waitpoint[R]

Public Class Methods

new(topic, qos) click to toggle source
Calls superclass method MQTT::Subscriptions::Subscription::new
# File lib/mqtt/subscription_classes.rb, line 36
def initialize(topic, qos)
        super(topic, qos);

        @waitpoint   = Xasin::Waitpoint.new();
end

Public Instance Methods

offer(topicList, data) click to toggle source
# File lib/mqtt/subscription_classes.rb, line 42
def offer(topicList, data)
        @waitpoint.fire([data, topicList]);
end