Struct actori::io::FramedWrite

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

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

Methods

impl<T: AsyncWrite + Unpin, U: Encoder> FramedWrite<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: U::Item)

Writes an item to the sink.

pub fn handle(&self) -> SpawnHandle

Returns the SpawnHandle for this writer.

Trait Implementations

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

fn drop(&mut self)

Executes the destructor for this type.