Struct veilid_tools::DeferredStreamProcessor

pub struct DeferredStreamProcessor {
    pub opt_deferred_stream_channel: Option<Sender<SendPinBoxFuture<()>>>,
    pub opt_stopper: Option<StopSource>,
    pub opt_join_handle: Option<MustJoinHandle<()>>,
}

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

Fields

opt_deferred_stream_channel: Option<Sender<SendPinBoxFuture<()>>>

opt_stopper: Option<StopSource>

opt_join_handle: Option<MustJoinHandle<()>>

Implementations

impl DeferredStreamProcessor

pub fn new() -> Self

Create a new DeferredStreamProcessor

pub async fn init(&mut self)

Initialize the processor before use

pub async fn terminate(&mut self)

Terminate the processor and ensure all streams are closed

pub fn add<T: Send + 'static>( &mut self, receiver: Receiver<T>, handler: impl FnMut(T) -> SendPinBoxFuture<bool> + 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

Trait Implementations

impl Default for DeferredStreamProcessor

fn default() -> Self

Returns the “default value” for a type.