TudbuT/conduit
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

remove unnecessary pubs

Browse source 
Signed-off-by: strawberry <strawberry@puppygock.gay>
This commit is contained in:
strawberry 2024-03-06 18:14:47 -05:00 • committed by June
parent 139b0fdc3e
commit e90cd48f61
1 changed files with 3 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

6
src/database/mod.rs
View file

@ -1012,7 +1012,7 @@ impl KeyValueDatabase {
} }
#[tracing::instrument] #[tracing::instrument]
pub fn start_check_for_updates_task() { fn start_check_for_updates_task() {
tokio::spawn(async move { tokio::spawn(async move {
let timer_interval = Duration::from_secs(60 * 60); let timer_interval = Duration::from_secs(60 * 60);
let mut i = interval(timer_interval); let mut i = interval(timer_interval);
@ -1060,7 +1060,7 @@ impl KeyValueDatabase {
} }
#[tracing::instrument] #[tracing::instrument]
pub async fn start_cleanup_task() { async fn start_cleanup_task() {
#[cfg(unix)] #[cfg(unix)]
use tokio::signal::unix::{signal, SignalKind}; use tokio::signal::unix::{signal, SignalKind};
use tokio::time::Instant; use tokio::time::Instant;
@ -1111,7 +1111,7 @@ impl KeyValueDatabase {
}); });
} }
pub async fn start_presence_handler(presence_timer_receiver: mpsc::UnboundedReceiver<(OwnedUserId, Duration)>) { async fn start_presence_handler(presence_timer_receiver: mpsc::UnboundedReceiver<(OwnedUserId, Duration)>) {
tokio::spawn(async move { tokio::spawn(async move {
match presence_handler(presence_timer_receiver).await { match presence_handler(presence_timer_receiver).await {
Ok(()) => warn!("Presence maintenance task finished"), Ok(()) => warn!("Presence maintenance task finished"),