Struct actix::io::FramedWrite

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

Wrapper for AsyncWrite and Encoder types

Implementations

impl<T: AsyncWrite, U: Encoder> FramedWrite<T, U>

pub fn new<A, C>(io: T, enc: U, ctx: &mut C) -> FramedWrite<T, U>where
    A: Actor<Context = C> + WriteHandler<U::Error>,
    C: AsyncContext<A>,
    U::Error: 'static,
    T: 'static,

pub fn from_buffer<A, C>(
    io: T,
    enc: U,
    buffer: BytesMut,
    ctx: &mut C
) -> FramedWrite<T, U>where
    A: Actor<Context = C> + WriteHandler<U::Error>,
    C: AsyncContext<A>,
    U::Error: 'static,
    T: 'static,

pub fn close(&mut self)

Gracefully close sink

Close process is asynchronous.

pub fn closed(&self) -> bool

Check if sink is closed

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

Set write buffer capacity

pub fn write(&mut self, item: U::Item)

Write item

pub fn handle(&self) -> SpawnHandle

SpawnHandle for this writer