Skip to main content

soma_mcp_client/upstream/relay/
lifecycle.rs

1use std::time::Instant;
2
3use super::cache::{RelayCache, RelayConnection};
4
5pub fn sweep_and_collect_shutdowns(cache: &mut RelayCache, now: Instant) -> Vec<RelayConnection> {
6    cache.sweep(now);
7    cache.take_pending_shutdown()
8}
9
10#[cfg(test)]
11#[path = "lifecycle_tests.rs"]
12mod tests;