Struct FrameWriter 

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

Async frame writer over any AsyncWrite stream.

Implementations

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

pub fn new(inner: W) -> Self

Wrap a writer.

pub async fn write_frame(&mut self, frame: &Frame) -> Result<(), TransportError>

Write a frame to the stream.

pub async fn write_data(&mut self, payload: &[u8]) -> Result<(), TransportError>

Write a data frame with the given payload.

pub async fn write_control( &mut self, payload: &[u8], ) -> Result<(), TransportError>

Write a control frame with the given payload.

pub async fn write_json<T: Serialize>( &mut self, value: &T, ) -> Result<(), TransportError>

Write a JSON-serializable value as a data frame.

pub fn inner(&self) -> &W

Get a reference to the inner writer.

pub fn into_inner(self) -> W

Consume the writer and return the inner stream.

Trait Implementations

impl<W: Debug> Debug for FrameWriter<W>

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

Formats the value using the given formatter.