Struct DataReaderInner 

pub(crate) struct DataReaderInner {
    state: Option<DataReaderState>,
    _memquota: StreamAccount,
    ctrl: Arc<ClientDataStreamCtrl>,
}

The inner reader for DataReader.

This type is responsible for taking stream messages and extracting the stream data from them. Flow control logic is implemented in DataReader to avoid making this type more complex.

Fields

state: Option<DataReaderState>

Internal state for this reader.

This is stored in an Option so that we can mutate it in poll_read(). It might be possible to do better here, and we should refactor if so.

_memquota: StreamAccount

The memory quota account that should be used for this stream’s data

Exists to keep the account alive

ctrl: Arc<ClientDataStreamCtrl>

A control object that can be used to monitor and control this stream without needing to own it.

Implementations

impl DataReaderInner

pub(crate) fn client_stream_ctrl(&self) -> &Arc<ClientDataStreamCtrl>

Return a ClientDataStreamCtrl object that can be used to monitor and interact with this stream without holding the stream itself.

Trait Implementations

impl AsyncRead for DataReaderInner

fn poll_read( self: Pin<&mut Self>, cx: &mut Context<'_>, buf: &mut [u8], ) -> Poll<IoResult<usize>>

Attempt to read from the AsyncRead into buf.

fn poll_read_vectored( self: Pin<&mut Self>, cx: &mut Context<'_>, bufs: &mut [IoSliceMut<'_>], ) -> Poll<Result<usize, Error>>

Attempt to read from the AsyncRead into bufs using vectored IO operations.

impl AsyncRead for DataReaderInner

Available on crate feature tokio only.

fn poll_read( self: Pin<&mut Self>, cx: &mut Context<'_>, buf: &mut ReadBuf<'_>, ) -> Poll<IoResult<()>>

Attempts to read from the AsyncRead into buf.

impl BufferIsEmpty for DataReaderInner

fn is_empty(self: Pin<&mut Self>) -> bool

The result will become stale, so is most accurate immediately after a poll_read.

impl Debug for DataReaderInner

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

Formats the value using the given formatter.