Trait rpc_it::transport::AsyncFrameRead

pub trait AsyncFrameRead: Send + Sync + 'static {
    // Required method
    fn poll_next(
        self: Pin<&mut Self>,
        cx: &mut Context<'_>
    ) -> Poll<Result<Bytes>>;
}

Required Methods

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

Implementors

impl AsyncFrameRead for InMemoryReader

impl<T: Stream<Item = Result<Bytes>> + Sync + Send + 'static> AsyncFrameRead for T