Trait fizyr_rpc::transport::TransportReadHalf

pub trait TransportReadHalf: Send + Unpin {
    type Body: Body;

    // Required method
    fn poll_read_msg(
        self: Pin<&mut Self>,
        context: &mut Context<'_>
    ) -> Poll<Result<Message<Self::Body>, TransportError>>;

    // Provided method
    fn read_msg(&mut self) -> ReadMsg<'_, Self> 
       where Self: Unpin { ... }
}

Trait for the read half of a transport type.

Required Associated Types

type Body: Body

The body type for messages transferred over the transport.

Required Methods

fn poll_read_msg( self: Pin<&mut Self>, context: &mut Context<'_> ) -> Poll<Result<Message<Self::Body>, TransportError>>

Try to read a message from the transport without blocking.

This function may read partial messages into an internal buffer.

If the function returns Poll::Pending, the current task is scheduled to wake when more data is available.

Provided Methods

fn read_msg(&mut self) -> ReadMsg<'_, Self>

where Self: Unpin,

Asynchronously read a complete message from the transport.

Object Safety

This trait is not object safe.

Implementations on Foreign Types

impl<P> TransportReadHalf for Pin<P>

where P: DerefMut + Send + Unpin, P::Target: TransportReadHalf,

type Body = <<P as Deref>::Target as TransportReadHalf>::Body

fn poll_read_msg( self: Pin<&mut Self>, context: &mut Context<'_> ) -> Poll<Result<Message<Self::Body>, TransportError>>

impl<T> TransportReadHalf for &mut T

where T: TransportReadHalf + Unpin + ?Sized,

type Body = <T as TransportReadHalf>::Body

fn poll_read_msg( self: Pin<&mut Self>, context: &mut Context<'_> ) -> Poll<Result<Message<Self::Body>, TransportError>>

impl<T> TransportReadHalf for Box<T>

where T: TransportReadHalf + Unpin + ?Sized,

type Body = <T as TransportReadHalf>::Body

fn poll_read_msg( self: Pin<&mut Self>, context: &mut Context<'_> ) -> Poll<Result<Message<Self::Body>, TransportError>>

Implementors