(self, conn, nbytes, flags=0)
| 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) |
| 511 | ov = _overlapped.Overlapped(NULL) |
| 512 | try: |
| 513 | ov.WSARecvFrom(conn.fileno(), nbytes, flags) |
| 514 | except BrokenPipeError: |
| 515 | return self._result((b'', None)) |
| 516 | |
| 517 | return self._register(ov, conn, partial(self._finish_recvfrom, |
| 518 | empty_result=b'')) |
| 519 | |
| 520 | def recvfrom_into(self, conn, buf, flags=0): |
| 521 | self._register_with_iocp(conn) |
no test coverage detected