(self, fut, sock, buf, bufsize)
| 514 | return await fut |
| 515 | |
| 516 | def _sock_recvfrom_into(self, fut, sock, buf, bufsize): |
| 517 | # _sock_recv_into() can add itself as an I/O callback if the operation |
| 518 | # can't be done immediately. Don't use it directly, call |
| 519 | # sock_recv_into(). |
| 520 | if fut.done(): |
| 521 | return |
| 522 | try: |
| 523 | result = sock.recvfrom_into(buf, bufsize) |
| 524 | except (BlockingIOError, InterruptedError): |
| 525 | return # try again next time |
| 526 | except (SystemExit, KeyboardInterrupt): |
| 527 | raise |
| 528 | except BaseException as exc: |
| 529 | fut.set_exception(exc) |
| 530 | else: |
| 531 | fut.set_result(result) |
| 532 | |
| 533 | async def sock_sendall(self, sock, data): |
| 534 | """Send data to the socket. |
nothing calls this directly
no test coverage detected