code: def disconnect(self):
          
          _LOGGING.debug('Disconnecting from stream: %s', self.name)
          self.kill_thrd.set()
          self.thrd.join()
          _LOGGING.debug('Event stream thread for %s is stopped', self.name)
          self.kill_thrd.clear()
docs: Disconnect from event stream.