Struct UserConfirmationPolicy 

pub struct UserConfirmationPolicy { /* private fields */ }

User confirmation policy: prompt user before compression.

Reads y/n input from an injected reader. Use Self::stdin() for interactive CLIs, or Self::new() with a custom reader (e.g. for tests).

The read runs inside tokio::task::spawn_blocking so it does not stall the async runtime.

Implementations

impl UserConfirmationPolicy

pub fn new(reader: impl BufRead + Send + 'static) -> Self

Create with a custom reader (e.g. Cursor<Vec<u8>> for tests).

pub fn stdin() -> Self

Create reading from stdin.

Trait Implementations

impl CompressionPolicy for UserConfirmationPolicy

fn should_compress<'life0, 'async_trait>( &'life0 self, tokens_before: usize, msg_count: usize, ) -> Pin<Box<dyn Future<Output = bool> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Called before compression starts.