tuwunel_admin/query/sending/active_requests.rs
1use futures::StreamExt;
2use tuwunel_core::Result;
3
4use crate::admin_command;
5
6#[admin_command]
7pub(super) async fn sending_active_requests(&self) -> Result {
8 let query = self
9 .services
10 .sending
11 .db
12 .active_requests()
13 .collect::<Vec<_>>();
14
15 self.write_timed_query(query).await
16}