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