Struct actix_web::actix::dev::io::FramedWrite

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

Wrapper for AsyncWrite and Encoder types

Implementations

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

pub fn new<A, C>(io: T, enc: U, ctx: &mut C) -> FramedWrite<T, U>where
    A: Actor<Context = C> + WriteHandler<<U as Encoder>::Error>,
    C: AsyncContext<A>,
    <U as Encoder>::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 as Encoder>::Error>,
    C: AsyncContext<A>,
    <U as Encoder>::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 as Encoder>::Item)

Write item

pub fn handle(&self) -> SpawnHandle

SpawnHandle for this writer