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

	match socket.io.get_ref().recv(buffer) {
		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(socket: &UnixSeqpacket, cx: &mut Context, buffer: &mut [u8]) -> Poll<std::io::Result<usize>> {
	let mut ready_guard = ready!(socket.io.poll_read_ready(cx)?);
	match socket.io.get_ref().recv(buffer) {
		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 ( socket : & UnixSeqpacket , cx : & mut Context , buffer : & mut [ u8 ] ) -> Poll < std :: io :: Result < usize > > { let mut ready_guard = ready ! ( socket io poll_read_ready ( cx ) ) ; match socket . io . get_ref ( ) . recv ( buffer ) { 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 [u8]