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

Pairs with terminate. Spawns the background task; not idempotent, calling it twice panics dropping the prior un-awaited join handle.

pub async fn terminate(&self)

Terminate the processor and ensure all streams are closed

Awaits the background task’s exit. Idempotent: a no-op once already terminated or never initialized.

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.

Non-blocking; the stream is processed by the background task until exhausted or terminate is called.

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

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

Queue a single future to process in the background

Non-blocking; returns false if the processor was not initialized. The future runs until done or terminate is called.

Trait Implementations

impl Clone for DeferredStreamProcessor

fn clone(&self) -> DeferredStreamProcessor

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

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.