Struct RecvFuture 

pub struct RecvFuture<'ring, 'buf> { /* private fields */ }

Future for socket receive operations.

This future receives data from a socket connection and returns the number of bytes received along with buffer ownership when the operation completes. The buffer will contain the received data upon successful completion.

Type Parameters

• 'ring - Lifetime of the io_uring Ring instance
• 'buf - Lifetime of the buffer to receive data into

Returns

Returns (usize, Pin<&'buf mut [u8]>) on success where:

• usize is the number of bytes received
• Pin<&'buf mut [u8]> is the buffer containing the received data

Examples

let mut ring = Ring::new(32)?;
let mut buffer = PinnedBuffer::with_capacity(1024);
let stream = TcpStream::connect("127.0.0.1:8080")?;
stream.set_nonblocking(true)?;

let recv_future = ring.recv(stream.as_raw_fd(), buffer.as_mut_slice())?;
let (bytes_received, _buffer) = recv_future.await?;

println!("Received {} bytes", bytes_received);

Trait Implementations

impl<'ring, 'buf> Drop for RecvFuture<'ring, 'buf>

fn drop(&mut self)

Executes the destructor for this type.

impl<'ring, 'buf> Future for RecvFuture<'ring, 'buf>

type Output = Result<(usize, Pin<&'buf mut [u8]>), Error>

The type of value produced on completion.

fn poll(self: StdPin<&mut Self>, cx: &mut Context<'_>) -> Poll<Self::Output>

Attempts to resolve the future to a final value, registering the current task for wakeup if the value is not yet available.