Struct Writer

pub struct Writer<T: AsyncWrite, E: From<Error>> { /* private fields */ }

A wrapper for AsyncWrite types.

Implementations

impl<T: AsyncWrite, E: From<Error> + 'static> Writer<T, E>

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

where A: Actor<Context = C> + WriteHandler<E>, C: AsyncContext<A>, 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_watermark: usize, high_watermark: usize, )

Sets the write buffer capacity.

pub fn write(&mut self, msg: &[u8])

Sends an item to the sink.

pub fn handle(&self) -> SpawnHandle

Returns the SpawnHandle for this writer.