Struct rmp_futures::encode::MsgPackWriter

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

Implementations

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

pub fn new(writer: W) -> Self

pub fn into_inner(self) -> W

pub async fn write_nil(self) -> IoResult<W>

pub async fn write_bool(self, val: bool) -> IoResult<W>

pub async fn write_int(self, val: impl Into<EfficientInt>) -> IoResult<W>

Write any int (u8-u64,i8-i64) in the most efficient representation

pub async fn write_f32(self, val: f32) -> IoResult<W>

pub async fn write_f64(self, val: f64) -> IoResult<W>

pub async fn write_array_len(self, len: u32) -> IoResult<ArrayFuture<W>>

pub async fn write_map_len(self, len: u32) -> IoResult<MapFuture<W>>

pub async fn write_bin_len(self, len: u32) -> IoResult<W>

Encodes and attempts to write the most efficient binary array length representation TODO: return binwriter

pub async fn write_bin(self, data: &[u8]) -> IoResult<W>

Encodes and attempts to write the most efficient binary representation

pub async fn write_str_len(self, len: u32) -> IoResult<W>

Encodes and attempts to write the most efficient binary array length representation TODO: return str writer

pub async fn write_str_bytes(self, string: &[u8]) -> IoResult<W>

Encodes and attempts to write the most efficient binary representation

pub async fn write_str(self, string: &str) -> IoResult<W>

Encodes and attempts to write the most efficient binary representation

pub async fn write_ext_meta(self, len: u32, ty: i8) -> IoResult<W>

Encodes and attempts to write the most efficient ext metadata representation

Panics

Panics if ty is negative, because it is reserved for future MessagePack extension including 2-byte type information.

pub async fn write_ext(self, data: &[u8], ty: i8) -> IoResult<W>

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

Encodes and attempts to write a dynamic rmpv::Value

Panics

Panics if array or map length exceeds 2^32-1

pub async fn write_value_ref(self, value: &ValueRef<'_>) -> IoResult<W>where
    W: Send,

Encodes and attempts to write a dynamic rmpv::ValueRef

Panics

Panics if array or map length exceeds 2^32-1

pub fn write_value_dyn<'a>(
    self,
    value: &'a Value
) -> Pin<Box<dyn Future<Output = IoResult<W>> + Send + 'a>>where
    W: Send + 'a,

pub fn write_value_ref_dyn<'a>(
    self,
    value: &'a ValueRef<'a>
) -> Pin<Box<dyn Future<Output = IoResult<W>> + Send + 'a>>where
    W: Send + 'a,

Trait Implementations

impl<W: AsyncWrite + Unpin> AsyncWrite for MsgPackWriter<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.