Struct DeferredStreamProcessor 

pub struct DeferredStreamProcessor { /* private fields */ }

Background processor for streams Handles streams to completion, passing each item from the stream to a callback

Implementations

impl DeferredStreamProcessor

pub fn new() -> Self

Create a new DeferredStreamProcessor

pub fn init(&self)

Initialize the processor before use

pub async fn terminate(&self)

Terminate the processor and ensure all streams are closed

pub fn add_stream<T: Send + 'static, S: Stream<Item = T> + Unpin + Send + 'static>( &self, receiver: S, handler: impl FnMut(T) -> PinBoxFutureStatic<DeferredStreamResult> + Send + 'static, ) -> bool

Queue a stream to process in the background

• ‘receiver’ is the stream to process
• ‘handler’ is the callback to handle each item from the stream

Returns ‘true’ if the stream was added for processing, and ‘false’ if the stream could not be added, possibly due to not being initialized.

pub fn add_future<F>(&self, fut: F) -> bool

where F: Future<Output = ()> + Send + 'static,

Queue a single future to process in the background

Trait Implementations

impl Debug for DeferredStreamProcessor

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

Formats the value using the given formatter.

impl Default for DeferredStreamProcessor

fn default() -> Self

Returns the “default value” for a type.