Commit de596547 authored by Kirill Smelkov's avatar Kirill Smelkov

.

parent f4b41e71
......@@ -482,7 +482,7 @@ class tWatch:
req = t.recvReq()
assert req is not None # channel not closed
assert req.msg in expected
expected.delete(req.msg)
expected.remove(req.msg)
reqv.append(req)
return reqv
......@@ -505,7 +505,7 @@ class tSrvReq:
with t._mu:
assert req.stream in t._accepted
t._accepted.delete(req.stream)
t._accepted.remove(req.stream)
# XXX also track as answered? (and don't accept with the same ID ?)
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment