Class: MQTT::Subscriptions::CallbackSubscription

Inherits:
Subscription
  • Object
show all
Defined in:
lib/mqtt/subscription_classes.rb

Instance Attribute Summary

Attributes inherited from Subscription

#qos, #topic, #topic_split

Instance Method Summary collapse

Constructor Details

#initialize(topic, qos, callback) ⇒ CallbackSubscription

Returns a new instance of CallbackSubscription.



23
24
25
26
27
# File 'lib/mqtt/subscription_classes.rb', line 23

def initialize(topic, qos, callback)
	super(topic, qos);

	@callback  	= callback;
end

Instance Method Details

#offer(topicList, data) ⇒ Object



28
29
30
# File 'lib/mqtt/subscription_classes.rb', line 28

def offer(topicList, data)
	@callback.call(data, topicList);
end