Struct StreamControlManager 

pub struct StreamControlManager;

Stream control utilities

Implementations

impl StreamControlManager

pub fn create_controlled_processor<T>( control: StreamControl, ) -> impl Fn(T) -> Option<T>

where T: Send + 'static,

Create a controlled stream processing function This returns a function that can process stream items with control

pub async fn with_cancellation<T, F, Fut>( token: CancellationToken, operation: F, ) -> Result<T, &'static str>

where F: FnOnce() -> Fut, Fut: Future<Output = T>,

Create a cancellable async operation

Errors

Returns an error if the operation is cancelled.

pub fn create_timeout_token(timeout: Duration) -> CancellationToken

Create a timeout-based cancellation token

pub fn combine_tokens(tokens: Vec<CancellationToken>) -> CancellationToken

Combine multiple cancellation tokens (any cancellation triggers all)

pub fn create_control_channel() -> (StreamControlSender, StreamControlReceiver)

Create a manual control channel for external control

Trait Implementations

impl Debug for StreamControlManager

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

Formats the value using the given formatter.