code: def on_stop(self):
          
          LOGGER.debug("zeromq.Subscriber.on_stop")
          self.running = False
          while self.is_started:
              time.sleep(0.1)
          self.zmqsocket.close()
          self.zmqcontext.destroy()
docs: stop subscriber