Struct FramedWrite

pub struct FramedWrite<I, T: AsyncWrite + Unpin, U: Encoder<I>> { /* private fields */ }

A wrapper for the AsyncWrite and Encoder types. The AsyncWrite will be flushed when this struct is dropped.

Implementations

impl<I, T: AsyncWrite + Unpin, U: Encoder<I>> FramedWrite<I, T, U>

pub fn new<A, C>(io: T, enc: U, ctx: &mut C) -> Self

where A: Actor<Context = C> + WriteHandler<U::Error>, C: AsyncContext<A>, U::Error: 'static, T: Unpin + 'static,

pub fn from_buffer<A, C>(io: T, enc: U, buffer: BytesMut, ctx: &mut C) -> Self

where A: Actor<Context = C> + WriteHandler<U::Error>, C: AsyncContext<A>, U::Error: 'static, T: Unpin + 'static,

pub fn close(&mut self)

Gracefully closes the sink.

The closing happens asynchronously.

pub fn closed(&self) -> bool

Checks if the sink is closed.

pub fn set_buffer_capacity(&mut self, low: usize, high: usize)

Sets the write buffer capacity.

pub fn write(&mut self, item: I)

Writes an item to the sink.

pub fn handle(&self) -> SpawnHandle

Returns the SpawnHandle for this writer.

Trait Implementations

impl<I, T: AsyncWrite + Unpin, U: Encoder<I>> Drop for FramedWrite<I, T, U>

fn drop(&mut self)

Executes the destructor for this type.