Struct ByWeight 

pub struct ByWeight<F: Fn(&Message) -> u64 + Send + Sync> {
    pub weight: F,
    pub threshold: u64,
}

Weighted-quorum completion: sum of weight(msg) over the group must reach threshold.

The canonical use case is voting-power quorums where each message carries its weight in a header — e.g. weight = |m| m.header("voting_power")?.parse().ok().

Fields

weight: F

threshold: u64

Trait Implementations

impl<F> CompletionCondition for ByWeight<F>

where F: Fn(&Message) -> u64 + Send + Sync,

fn is_complete(&self, group: &[Message], _first_seen: Instant) -> bool

Return true if group (the current accumulated messages, in arrival order) is complete. first_seen is when the first message of this group arrived; useful for time-based conditions.