Commit 87aa4856 authored by Lars Kuipers's avatar Lars Kuipers
parents 54102605 d05aa26b
......@@ -451,12 +451,16 @@ class _Stream:
self.send_syn_nr = self.__next_seq(self.send_syn_nr)
self.sender_closed = True
time.sleep(self.timeout * 4)
def close_receiver(self) -> None:
logging.debug(self.deb + "Waiting for remote host to close")
self.receiver_closed_lock.acquire()
self.receiver_closed_event.wait_for(lambda: self.receiver_closed)
self.receiver_closed_lock.release()
time.sleep(self.timeout * 4)
class _Connection:
def __init__(self, parent: Union["_Server", "Binding"], stream: _Stream):
......
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