Struct yz_packet_stream::PacketStream

pub struct PacketStream<T> { /* fields omitted */ }

Implementations

impl<T> PacketStream<T>

pub fn new(stream: T) -> Self

impl<T> PacketStream<T> where
    T: AsyncWrite + Debug, 

pub fn enqueue<B: AsRef<[u8]>>(
    self: Pin<&mut Self>,
    item: B
) -> Result<(), Error>

generic sending method

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

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

impl<T> PacketStream<T>

pub fn get_ref(&self) -> &T

Trait Implementations

impl<T: Debug> Debug for PacketStream<T>

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

Formats the value using the given formatter.

impl<T> FusedStream for PacketStream<T> where
    T: AsyncRead + Debug, 

fn is_terminated(&self) -> bool

Returns true if the stream should no longer be polled.

impl<T> Stream for PacketStream<T> where
    T: AsyncRead + Debug, 

type Item = Result<Vec<u8>>

Values yielded by the stream.

fn poll_next(
    self: Pin<&mut Self>,
    cx: &mut Context<'_>
) -> Poll<Option<Self::Item>>

Attempt to pull out the next value of this stream, registering the current task for wakeup if the value is not yet available, and returning None if the stream is exhausted.

fn size_hint(&self) -> (usize, Option<usize>)

Returns the bounds on the remaining length of the stream.

impl<'__pin, T> Unpin for PacketStream<T> where
    __Origin<'__pin, T>: Unpin,