Struct AsyncReadAdapter 

pub struct AsyncReadAdapter<S> { /* private fields */ }

Wraps a tokio::io::AsyncRead + AsyncWrite source as a WireStream.

Use this when constructing WsStream/HttpConnection over a custom tokio transport (raw TcpStream, mock streams, etc.). The canonical MaybeTls transport implements WireStream directly.

use nexus_async_net::AsyncReadAdapter;

let tcp = tokio::net::TcpStream::connect(addr).await?;
let ws = WsStreamBuilder::new()
    .connect_with(AsyncReadAdapter::new(tcp), url)
    .await?;

Implementations

impl<S> AsyncReadAdapter<S>

pub fn new(inner: S) -> Self

Wrap an inner AsyncRead+AsyncWrite stream.

pub fn get_ref(&self) -> &S

Access the inner stream.

pub fn get_mut(&mut self) -> &mut S

Mutable access to the inner stream.

pub fn into_inner(self) -> S

Decompose into the inner stream.

Trait Implementations

impl<S: AsyncRead + AsyncWrite + Unpin> WireStream for AsyncReadAdapter<S>

Available on crate feature tokio-rt only.

fn poll_fill_into<P: ParserSink>( self: Pin<&mut Self>, cx: &mut Context<'_>, sink: &mut P, max: usize, ) -> Poll<Result<usize>>

Read bytes into sink.spare(). Returns the number of bytes actually delivered to the sink. Ok(0) indicates EOF.

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

Write buf to the transport. Returns the number of bytes accepted (may be less than buf.len()). Ok(0) may indicate the transport cannot accept more right now or that the underlying connection has been closed for writes — same semantics as tokio::io::AsyncWrite::poll_write. Implementors of new transports should mirror that contract.

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

Flush bytes previously written via poll_write to the transport. Returns Poll::Ready(Ok(())) once all buffered data has been pushed to the underlying socket. Mirrors tokio::io::AsyncWrite::poll_flush.

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

Shut down the write side of the transport. For TLS-bearing implementations, send close_notify first and flush before closing the underlying connection. Mirrors tokio::io::AsyncWrite::poll_shutdown.