Struct OutputStream

pub struct OutputStream { /* private fields */ }

Implementations

impl OutputStream

pub fn ty(&self) -> OutputType

pub fn subscribe(&self) -> Receiver<Option<String>>

pub fn inspect(&self, f: impl Fn(String) + Send + 'static) -> Inspector

pub fn inspect_async<F>(&self, f: F) -> Inspector

where F: Fn(String) -> Pin<Box<dyn Future<Output = Result<(), Box<dyn Error + Send + Sync>>> + Send>> + Send + 'static,

pub fn collect<S: Sink>( &self, into: S, collect: impl Fn(String, &mut S) + Send + 'static, ) -> Collector<S>

pub fn collect_async<S, F>(&self, into: S, collect: F) -> Collector<S>

where S: Sink, F: Fn(String, &mut S) -> Pin<Box<dyn Future<Output = Result<(), Box<dyn Error + Send + Sync>>> + Send + '_>> + Send + 'static,

pub fn collect_into_vec(&self) -> Collector<Vec<String>>

pub fn collect_into_write<W: Sink + AsyncWriteExt + Unpin>( &self, write: W, ) -> Collector<W>

pub fn collect_into_write_mapped<W: Sink + AsyncWriteExt + Unpin, B: AsRef<[u8]> + Send>( &self, write: W, mapper: impl Fn(String) -> B + Send + Sync + Copy + 'static, ) -> Collector<W>

pub async fn wait_for( &self, predicate: impl Fn(String) -> bool + Send + 'static, ) -> WaitFor

This function is cancel safe.

pub async fn wait_for_with_timeout( &self, predicate: impl Fn(String) -> bool + Send + 'static, timeout: Duration, ) -> Result<WaitFor, Elapsed>

This function is cancel safe.

Trait Implementations

impl Debug for OutputStream

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Drop for OutputStream

fn drop(&mut self)

Executes the destructor for this type.