Struct respite::RespWriter

pub struct RespWriter<Inner: AsyncWrite + Unpin> {
    pub version: RespVersion,
    /* private fields */
}

A wrapper for AsyncWrite to allow writing a RESP stream.

Fields

version: RespVersion

The current version.

Implementations

impl<Inner: AsyncWrite + Unpin> RespWriter<Inner>

pub fn new(inner: Inner) -> Self

Create a new RespWriter from an AsyncWrite.

pub async fn flush(&mut self) -> Result<(), RespError>

Flush the inner writer.

pub async fn write_array(&mut self, len: usize) -> Result<(), RespError>

Write an array frame.

pub async fn write_attribute(&mut self, value: &[u8]) -> Result<(), RespError>

Write an attribute frame.

pub async fn write_bignum(&mut self, value: &[u8]) -> Result<(), RespError>

Write a bignum frame.

pub async fn write_blob_error(&mut self, value: &[u8]) -> Result<(), RespError>

Write a blob error frame.

pub async fn write_blob_string(&mut self, value: &[u8]) -> Result<(), RespError>

Write a blob string frame.

pub async fn write_boolean(&mut self, value: bool) -> Result<(), RespError>

Write a boolean frame.

pub async fn write_double(&mut self, value: f64) -> Result<(), RespError>

Write a double frame.

pub async fn write_integer(&mut self, value: i64) -> Result<(), RespError>

Write an integer frame.

pub async fn write_nil(&mut self) -> Result<(), RespError>

Write a nil frame.

pub async fn write_map(&mut self, len: usize) -> Result<(), RespError>

Write a map frame.

pub async fn write_push(&mut self, len: usize) -> Result<(), RespError>

Write a push frame.

pub async fn write_set(&mut self, len: usize) -> Result<(), RespError>

Write a set frame.

pub async fn write_simple_error( &mut self, value: &[u8] ) -> Result<(), RespError>

Write a simple error frame.

pub async fn write_simple_string( &mut self, value: &[u8] ) -> Result<(), RespError>

Write a simple string frame.

pub async fn write_verbatim( &mut self, format: &[u8], value: &[u8] ) -> Result<(), RespError>

Write a verbatim frame.

Trait Implementations

impl<Inner: Debug + AsyncWrite + Unpin> Debug for RespWriter<Inner>

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

Formats the value using the given formatter.