This commit is contained in:
yumoqing 2021-11-25 10:15:43 +08:00
parent d886515b28
commit 6d1db413a7

View File

@ -100,7 +100,7 @@ class TopicSubscriber:
for t in self.topic:
self.sub.setsockopt(zmq.SUBSCRIBE, t.encode('utf-8'))
else:
self.sub.setsockopt(zmq.SUBSCRIBE, self.topic.encode('utf-8')
self.sub.setsockopt(zmq.SUBSCRIBE, self.topic.encode('utf-8'))
def run(self):