(self, sock, buf)
return await fut
Receive data from the socket.

        The received data is written into *buf* (a writable buffer).
        The return value is the number of bytes written.
Receive data from the socket.
Receive data from the socket .
async def sock_recv_into(self, sock, buf):
        """Receive data from the socket.

        The received data is written into *buf* (a writable buffer).
        The return value is the number of bytes written.
        """
        _check_ssl_socket(sock)
        if self._debug and sock.gettimeout() != 0:
            raise ValueError("the socket must be non-blocking")
        try:
            return sock.recv_into(buf)
        except (BlockingIOError, InterruptedError):
            pass
        fut = self.create_future()
        fd = sock.fileno()
        self._ensure_fd_no_transport(fd)
        handle = self._add_reader(fd, self._sock_recv_into, fut, sock, buf)
        fut.add_done_callback(
            functools.partial(self._sock_read_done, fd, handle=handle))
        return await fut
async def sock_recv_into ( self , sock , buf ) : _check_ssl_socket ( sock ) if self . _debug and sock . gettimeout ( ) != 0 : raise ValueError ( "the socket must be non-blocking" ) try : return sock . recv_into ( buf ) except ( BlockingIOError , InterruptedError ) : pass fut = self . create_future ( ) fd = sock . fileno ( ) self . _ensure_fd_no_transport ( fd ) handle = self . _add_reader ( fd , self . _sock_recv_into , fut , sock , buf ) fut . add_done_callback ( functools . partial ( self . _sock_read_done , fd , handle = handle ) ) return await fut