- self.sock.send(buf)
- try:
- self.sock.recv(4096, MSG_DONTWAIT)
- except BlockingIOError:
- pass
+ send_and_drain(self.sock, buf)
+
+ def test_msgs(self) -> None:
+ for _ in range(REPEAT):
+ size = self.rnd.randint(0, 300)
+ buf = b"xx" + self.rnd.randbytes(size) + b"\r\n"
+ send_and_drain(self.sock, buf)