Skip to content
This repository was archived by the owner on Oct 9, 2023. It is now read-only.

Commit fca5194

Browse files
remove dead code
1 parent 4b983a6 commit fca5194

File tree

1 file changed

+0
-4
lines changed

1 file changed

+0
-4
lines changed

typedb/stream/response_collector.py

Lines changed: 0 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -45,10 +45,6 @@ def new_queue(self, request_id: UUID):
4545
def get(self, request_id: UUID) -> Optional["ResponseCollector.Queue[R]"]:
4646
return self._response_queues.get(request_id)
4747

48-
def remove(self, request_id: UUID):
49-
with self._collectors_lock:
50-
del self._response_queues[request_id]
51-
5248
def close(self, error: Optional[TypeDBClientException]):
5349
with self._collectors_lock:
5450
for collector in self._response_queues.values():

0 commit comments

Comments
 (0)