Struct GuardedStreamWriter

pub struct GuardedStreamWriter<T, A>
where
    A: AsAccessor,
{ /* private fields */ }

Available on crate features runtime and component-model and component-model-async only.

A StreamWriter paired with an [Accessor].

This is an RAII wrapper around StreamWriter that ensures it is closed when dropped. This can be created through GuardedStreamWriter::new or StreamWriter::guard.

Implementations

impl<T, A> GuardedStreamWriter<T, A>

where A: AsAccessor,

pub fn new(accessor: A, writer: StreamWriter<T>) -> Self

Create a new GuardedStreamWriter with the specified accessor and writer.

pub fn is_closed(&self) -> bool

Wrapper for StreamWriter::is_closed.

pub async fn write<B>(&mut self, buffer: B) -> B

where T: Lower + 'static, B: WriteBuffer<T>,

Wrapper for StreamWriter::write.

pub async fn write_all<B>(&mut self, buffer: B) -> B

where T: Lower + 'static, B: WriteBuffer<T>,

Wrapper for StreamWriter::write_all.

pub async fn watch_reader(&mut self)

Wrapper for StreamWriter::watch_reader.

pub fn into_stream(self) -> StreamWriter<T>

Extracts the underlying StreamWriter from this guard, returning it back.

Trait Implementations

impl<T, A> Drop for GuardedStreamWriter<T, A>

where A: AsAccessor,

fn drop(&mut self)

Executes the destructor for this type.

impl<T, A> From<GuardedStreamWriter<T, A>> for StreamWriter<T>

where A: AsAccessor,

fn from(guard: GuardedStreamWriter<T, A>) -> Self

Converts to this type from the input type.