Function get_log_event

chirpstack/src/integration/mock.rs:147–159

()

}

pub async fn get_log_event() -> Option<integration::LogEvent> {
    if LOG_EVENTS.read().await.is_empty() {
        return None;
    }

    LOG_EVENTS
        .write()
        .await
        .drain(0..1)
        .collect::<Vec<integration::LogEvent>>()
        .first()
        .cloned()
}

pub async fn get_join_events() -> Vec<integration::JoinEvent> {
    JOIN_EVENTS.write().await.drain(..).collect()