Enum CompletionCondition 

pub enum CompletionCondition {
    Size(usize),
    Predicate(Arc<dyn Fn(&[Exchange]) -> bool + Send + Sync>),
}

When the bucket is considered complete and should be emitted.

Variants

Size(usize)

Emit when bucket reaches exactly N exchanges.

Predicate(Arc<dyn Fn(&[Exchange]) -> bool + Send + Sync>)

Emit when predicate returns true for current bucket.

Trait Implementations

impl Clone for CompletionCondition

fn clone(&self) -> CompletionCondition

Returns a duplicate of the value.

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

Performs copy-assignment from source.