pub(crate) fn poll_recv_vectored_with_ancillary(
	socket: &UnixSeqpacket,
	cx: &mut Context,
	buffer: &mut [IoSliceMut],
	ancillary: &mut SocketAncillary,
) -> Poll<std::io::Result<usize>> {
	let mut ready_guard = ready!(socket.io.poll_read_ready(cx)?);

	match recv_msg(socket.io.get_ref(), buffer, ancillary) {
		Err(ref e) if e.kind() == std::io::ErrorKind::WouldBlock => {
			ready_guard.clear_ready();
			Poll::Pending
		},
		x => Poll::Ready(x),
	}
}
/// Receive data on the socket from the connected peer without blocking.
Receive data on the socket from the connected peer without blocking.
Receive data on the socket from the connected peer without blocking .
pub(crate) fn poll_recv_vectored_with_ancillary(
	socket: &UnixSeqpacket,
	cx: &mut Context,
	buffer: &mut [IoSliceMut],
	ancillary: &mut SocketAncillary,
) -> Poll<std::io::Result<usize>> {
	let mut ready_guard = ready!(socket.io.poll_read_ready(cx)?);
	match recv_msg(socket.io.get_ref(), buffer, ancillary) {
		Err(ref e) if e.kind() == std::io::ErrorKind::WouldBlock => {
			ready_guard.clear_ready();
			Poll::Pending
		},
		x => Poll::Ready(x),
	}
}
pub ( crate ) fn poll_recv_vectored_with_ancillary ( socket : & UnixSeqpacket , cx : & mut Context , buffer : & mut [ IoSliceMut ] , ancillary : & mut SocketAncillary , ) -> Poll < std :: io :: Result < usize > > { let mut ready_guard = ready ! ( socket io poll_read_ready ( cx ) ) ; match recv_msg ( socket . io . get_ref ( ) , buffer , ancillary ) { Err ( ref e ) if e . kind ( ) == std :: io :: ErrorKind :: WouldBlock => { ready_guard . clear_ready ( ) ; Poll :: Pending } , x => Poll :: Ready ( x ) , } }
Receive data on the socket from the connected peer without blocking.
Receive data on the socket from the connected peer without blocking .
socket
&UnixSeqpacket
cx
&mut Context
buffer
&mut [IoSliceMut]
ancillary
&mut SocketAncillary