Struct PipeStream

pub struct PipeStream<R, T>
where
    R: for<'de> Deserialize<'de> + Serialize,
    T: AsyncRead + AsyncWrite,
{ /* private fields */ }

Implementations

impl<R, T> PipeStream<R, T>

where R: for<'de> Deserialize<'de> + Serialize, T: AsyncRead + AsyncWrite + Unpin,

pub fn new(stream: T) -> Self

创建一个管道的流，用于发送和接收数据。 其中传输的数据是实现了Deserialize 和 Serialize接口的struct。

pub async fn recv(&mut self) -> Result<R, PipeStreamError>

接收一个数据包。

pub async fn send(&mut self, packet: &R) -> Result<(), PipeStreamError>

发送一个数据包。 packet 实现了序列化接口的数据。

Trait Implementations

impl<R, T> Debug for PipeStream<R, T>

where R: for<'de> Deserialize<'de> + Serialize + Debug, T: AsyncRead + AsyncWrite + Debug,

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

Formats the value using the given formatter.