Struct TryStreamEmitter 

pub struct TryStreamEmitter<T, E> { /* private fields */ }

An intermediary that transfers values from stream to its consumer

Implementations

impl<T, E> TryStreamEmitter<T, E>

pub fn emit(&self, value: T) -> EmitFuture<'_, Result<T, E>>

Emit value from a stream and wait until stream consumer calls futures_util::StreamExt::next again.

Panics

Will panic if:

• emit/emit_err is called twice without awaiting result of the first call
• emit is called not in context of polling the stream

pub fn emit_err(&self, err: E) -> EmitFuture<'_, Result<T, E>>

Emit error from a stream and wait until stream consumer calls futures_util::StreamExt::next again.

Panics

Will panic if:

• emit/emit_err is called twice without awaiting result of the first call
• emit_err is called not in context of polling the stream

Trait Implementations

impl<T: RefUnwindSafe, E: RefUnwindSafe> RefUnwindSafe for TryStreamEmitter<T, E>

impl<T: Send, E: Send> Send for TryStreamEmitter<T, E>

impl<T: Send, E: Send> Sync for TryStreamEmitter<T, E>

impl<T: UnwindSafe, E: UnwindSafe> UnwindSafe for TryStreamEmitter<T, E>