unregister completely

This commit is contained in:
meejah 2021-02-12 01:16:33 -07:00
parent 40919b51be
commit 5ed572187b

View File

@ -153,8 +153,14 @@ class PendingRequests(object):
self._active = active_connections
def unregister(self, token, side, tc):
"""
We no longer care about a particular client (e.g. it has
disconnected).
"""
if token in self._requests:
self._requests[token].discard((side, tc))
if not self._requests[token]:
del self._requests[token]
self._active.unregister(tc)
def register_token(self, token, new_side, new_tc):