Struct ValueCollector 

pub struct ValueCollector { /* private fields */ }

Collector for subscription values with thread-safe access

Implementations

impl ValueCollector

pub fn new() -> Self

pub fn callback(&self) -> impl Fn(Value, String) + Send + 'static

Create a callback function for subscriptions

pub fn callback_ref(&self) -> impl Fn(Value, &str) + Send + Sync + 'static

Create a callback function for subscriptions that takes &str address

pub fn count(&self) -> u32

Get the count of received values

pub async fn wait_for_count(&self, n: u32, max_wait: Duration) -> bool

Wait for at least n values to be received

pub fn values(&self) -> Vec<(String, Value)>

Get all collected values

pub fn has_address(&self, addr: &str) -> bool

Check if a specific address was received

pub fn values_for(&self, addr: &str) -> Vec<Value>

Get values for a specific address pattern

pub fn last_value(&self) -> Option<(String, Value)>

Get the last value received

pub fn clear(&self)

Clear all collected values

Trait Implementations

impl Clone for ValueCollector

fn clone(&self) -> ValueCollector

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Default for ValueCollector

fn default() -> Self

Returns the “default value” for a type.