def close(self):
if not self._location:
self.unregister()
self._subscribers = set()
self._scheduler._lock.acquire()
self._scheduler._channels.pop(self._name, None)
self._scheduler._lock.release()