def subscribe(self, topic=b'<STR_LIT>'):
self.sockets[zmq.SUB].setsockopt(zmq.SUBSCRIBE, topic)<EOL>poller = self.pollers[zmq.SUB]<EOL>return poller<EOL>
subscribe to the SUB socket, to listen for incomming variables, return a stream that can be listened to.