Struct AsyncRdmaStream 

pub struct AsyncRdmaStream<T: Transport> { /* private fields */ }

An async RDMA stream with read and write methods.

Generic over T: Transport. Construct via AsyncRdmaStream::new with a pre-built transport.

Implementations

impl<T: Transport> AsyncRdmaStream<T>

pub fn new(transport: T) -> Self

Wrap a pre-constructed transport as a byte stream.

pub async fn read(&mut self, buf: &mut [u8]) -> Result<usize>

Read data from the stream asynchronously.

Returns the number of bytes read. Returns Ok(0) on disconnect (EOF).

pub async fn write(&mut self, data: &[u8]) -> Result<usize>

Write data to the stream asynchronously.

Returns the number of bytes written (bounded by buffer size).

pub async fn write_all(&mut self, data: &[u8]) -> Result<()>

Write all data to the stream, looping if necessary.

pub async fn shutdown(&mut self) -> Result<()>

Disconnect the stream gracefully.

pub fn peer_addr(&self) -> Option<SocketAddr>

Get the peer’s socket address (remote end of the connection).

pub fn local_addr(&self) -> Option<SocketAddr>

Get the local socket address.

Trait Implementations

impl<T: Transport> AsyncRead for AsyncRdmaStream<T>

fn poll_read( self: Pin<&mut Self>, cx: &mut Context<'_>, buf: &mut [u8], ) -> Poll<Result<usize>>

Attempt to read from the AsyncRead into buf.

fn poll_read_vectored( self: Pin<&mut Self>, cx: &mut Context<'_>, bufs: &mut [IoSliceMut<'_>], ) -> Poll<Result<usize, Error>>

Attempt to read from the AsyncRead into bufs using vectored IO operations.

impl<T: Transport> AsyncWrite for AsyncRdmaStream<T>

fn poll_write( self: Pin<&mut Self>, cx: &mut Context<'_>, buf: &[u8], ) -> Poll<Result<usize>>

Attempt to write bytes from buf into the object.

fn poll_flush(self: Pin<&mut Self>, _cx: &mut Context<'_>) -> Poll<Result<()>>

Attempt to flush the object, ensuring that any buffered data reach their destination.

fn poll_close(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Result<()>>

Attempt to close the object.

fn poll_write_vectored( self: Pin<&mut Self>, cx: &mut Context<'_>, bufs: &[IoSlice<'_>], ) -> Poll<Result<usize, Error>>

Attempt to write bytes from bufs into the object using vectored IO operations.

impl<T: Transport> Debug for AsyncRdmaStream<T>

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl<T: Transport> Drop for AsyncRdmaStream<T>

fn drop(&mut self)

Executes the destructor for this type.

impl<T: Transport> Unpin for AsyncRdmaStream<T>