(self, fut, sock, buf)
| 432 | return await fut |
| 433 | |
| 434 | def _sock_recv_into(self, fut, sock, buf): |
| 435 | # _sock_recv_into() can add itself as an I/O callback if the operation |
| 436 | # can't be done immediately. Don't use it directly, call |
| 437 | # sock_recv_into(). |
| 438 | if fut.done(): |
| 439 | return |
| 440 | try: |
| 441 | nbytes = sock.recv_into(buf) |
| 442 | except (BlockingIOError, InterruptedError): |
| 443 | return # try again next time |
| 444 | except (SystemExit, KeyboardInterrupt): |
| 445 | raise |
| 446 | except BaseException as exc: |
| 447 | fut.set_exception(exc) |
| 448 | else: |
| 449 | fut.set_result(nbytes) |
| 450 | |
| 451 | async def sock_recvfrom(self, sock, bufsize): |
| 452 | """Receive a datagram from a datagram socket. |
nothing calls this directly
no test coverage detected