(self, conn, buf, flags=0)
| 494 | return self._register(ov, conn, self.finish_socket_func) |
| 495 | |
| 496 | def recv_into(self, conn, buf, flags=0): |
| 497 | self._register_with_iocp(conn) |
| 498 | ov = _overlapped.Overlapped(NULL) |
| 499 | try: |
| 500 | if isinstance(conn, socket.socket): |
| 501 | ov.WSARecvInto(conn.fileno(), buf, flags) |
| 502 | else: |
| 503 | ov.ReadFileInto(conn.fileno(), buf) |
| 504 | except BrokenPipeError: |
| 505 | return self._result(0) |
| 506 | |
| 507 | return self._register(ov, conn, self.finish_socket_func) |
| 508 | |
| 509 | def recvfrom(self, conn, nbytes, flags=0): |
| 510 | self._register_with_iocp(conn) |
no test coverage detected