@@ -253,12 +253,14 @@ def subscribe(self, feed_key=None, group_key=None, shared_user=None):
253
253
254
254
client.subscribe([('temperature'), ('humidity')])
255
255
"""
256
- validate_feed_key (feed_key )
257
256
if shared_user is not None and feed_key is not None :
257
+ validate_feed_key (feed_key )
258
258
self ._client .subscribe ("{0}/f/{1}" .format (shared_user , feed_key ))
259
259
elif group_key is not None :
260
+ validate_feed_key (group_key )
260
261
self ._client .subscribe ("{0}/g/{1}" .format (self ._user , group_key ))
261
262
elif feed_key is not None :
263
+ validate_feed_key (feed_key )
262
264
self ._client .subscribe ("{0}/f/{1}" .format (self ._user , feed_key ))
263
265
else :
264
266
raise AdafruitIO_MQTTError ("Must provide a feed_key or group_key." )
@@ -333,12 +335,14 @@ def unsubscribe(self, feed_key=None, group_key=None, shared_user=None):
333
335
client.unsubscribe('temperature', shared_user='adabot')
334
336
335
337
"""
336
- validate_feed_key (feed_key )
337
338
if shared_user is not None and feed_key is not None :
339
+ validate_feed_key (feed_key )
338
340
self ._client .unsubscribe ("{0}/f/{1}" .format (shared_user , feed_key ))
339
341
elif group_key is not None :
342
+ validate_feed_key (group_key )
340
343
self ._client .unsubscribe ("{0}/g/{1}" .format (self ._user , feed_key ))
341
344
elif feed_key is not None :
345
+ validate_feed_key (feed_key )
342
346
self ._client .unsubscribe ("{0}/f/{1}" .format (self ._user , feed_key ))
343
347
else :
344
348
raise AdafruitIO_MQTTError ("Must provide a feed_key or group_key." )
0 commit comments