Struct SendFuture 

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

Future for socket send operations.

This future sends data over a socket connection and returns the number of bytes sent along with buffer ownership when the operation completes. The future handles partial sends and error conditions appropriately.

Type Parameters

• 'ring - Lifetime of the io_uring Ring instance
• 'buf - Lifetime of the buffer containing data to send

Returns

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

• usize is the number of bytes sent
• Pin<&'buf mut [u8]> is the buffer that was sent from

Examples

let mut ring = Ring::new(32)?;
let mut buffer = PinnedBuffer::from_slice(b"Hello, client!");
let stream = TcpStream::connect("127.0.0.1:8080")?;
stream.set_nonblocking(true)?;

let send_future = ring.send(stream.as_raw_fd(), buffer.as_mut_slice())?;
let (bytes_sent, _buffer) = send_future.await?;

println!("Sent {} bytes", bytes_sent);

Trait Implementations

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

fn drop(&mut self)

Executes the destructor for this type.

impl<'ring, 'buf> Future for SendFuture<'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.