Struct StreamLink 

pub struct StreamLink<R, W> { /* private fields */ }

A Link over a byte stream with length-prefix framing.

Wraps an AsyncRead + AsyncWrite pair. Each message is framed as [len: u32 LE][payload bytes].

Implementations

impl<R, W> StreamLink<R, W>

pub fn new(reader: R, writer: W) -> Self

Construct from separate read and write halves.

impl StreamLink<OwnedReadHalf, OwnedWriteHalf>

pub fn tcp(stream: TcpStream) -> Self

Wrap a TcpStream.

impl StreamLink<Stdin, Stdout>

pub fn stdio() -> Self

Wrap stdio (stdin for reading, stdout for writing).

impl StreamLink<OwnedReadHalf, OwnedWriteHalf>

pub fn unix(stream: UnixStream) -> Self

Wrap a UnixStream.

Trait Implementations

impl<R, W> Link for StreamLink<R, W>

where R: AsyncRead + Send + Unpin + 'static, W: AsyncWrite + Send + Unpin + 'static,

type Tx = StreamLinkTx

type Rx = StreamLinkRx<BufReader<R>>

fn split(self) -> (Self::Tx, Self::Rx)

fn supports_transport_mode(mode: TransportMode) -> bool

where Self: Sized,

Whether this link supports the requested transport mode.