Struct actix::io::FramedWrite

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

Wrapper for AsyncWrite and Encoder types

Methods

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