Skip to main content

drain_until

aether_core::testing

Function drain_until 

Source 
pub async fn drain_until(
    receiver: &mut Receiver<AgentEvent>,
    predicate: impl Fn(&AgentEvent) -> bool,
) -> Vec<AgentEvent>