Struct SinkWrite

pub struct SinkWrite<I, S: Sink<I> + Unpin> { /* private fields */ }

A wrapper for the Sink type.

Implementations

impl<I: 'static, S: Sink<I> + Unpin + 'static> SinkWrite<I, S>

pub fn new<A, C>(sink: S, ctxt: &mut C) -> Self

where A: Actor<Context = C> + WriteHandler<S::Error>, C: AsyncContext<A>,

pub fn write(&mut self, item: I) -> Result<(), I>

Queues an item to be sent to the sink.

Returns unsent item if sink is closing or closed.

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 handle(&self) -> SpawnHandle

Returns the SpawnHandle for this writer.