Struct rmp_futures::encode::MapFuture

pub struct MapFuture<W> { /* private fields */ }

Implementations

impl<W: AsyncWrite + Unpin> MapFuture<W>

pub fn len(&self) -> usize

pub fn is_empty(&self) -> bool

pub fn end(self) -> W

Return the underlying writer from this MapFuture that has already written all elements (len == 0).

#Panics

Panics if self.is_empty() is false. next() must have been called as many times as the map length originally written before calling this to destroy the array wrapper.

pub fn next_key(self) -> MsgPackOption<MsgPackWriter<MsgPackWriter<Self>>, W>

pub fn next_key_dyn(
    &mut self
) -> Option<MsgPackWriter<MsgPackWriter<&mut (dyn AsyncWrite + Send + Unpin)>>>where
    W: Send,

pub fn last_key(self) -> MsgPackOption<MsgPackWriter<MsgPackWriter<W>>, W>

If this is the last element, return a future of it’s value wrapped around the underlying writer. Avoids having to call next() a final time.

pub async fn write_value(self, a: &[(Value, Value)]) -> IoResult<W>where
    W: Send,

pub async fn write_value_ref<'a>(
    self,
    a: &[(ValueRef<'a>, ValueRef<'a>)]
) -> IoResult<W>where
    W: Send,

Trait Implementations

impl<W: AsyncWrite + Unpin> AsyncWrite for MapFuture<W>

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

Attempt to write bytes from buf into the object.

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

Attempt to flush the object, ensuring that any buffered data reach their destination.

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

Attempt to close the object.

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

Attempt to write bytes from bufs into the object using vectored IO operations.

impl<W: Debug> Debug for MapFuture<W>

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

Formats the value using the given formatter.