mirror of
https://forgejo.ellis.link/continuwuation/continuwuity.git
synced 2025-07-13 04:57:38 +02:00
fix ci
This commit is contained in:
parent
ce0ac32143
commit
eac36ad87b
2 changed files with 2 additions and 5 deletions
|
@ -170,7 +170,7 @@ impl Service {
|
|||
|
||||
async fn handler(&self) -> Result<()> {
|
||||
let mut presence_timers = FuturesUnordered::new();
|
||||
let mut receiver = self.timer_receiver.lock().await;
|
||||
let receiver = self.timer_receiver.lock().await;
|
||||
loop {
|
||||
tokio::select! {
|
||||
event = receiver.recv_async() => {
|
||||
|
|
|
@ -25,10 +25,7 @@ use ruma::{
|
|||
events::{push_rules::PushRulesEvent, receipt::ReceiptType, AnySyncEphemeralRoomEvent, GlobalAccountDataEventType},
|
||||
push, uint, MilliSecondsSinceUnixEpoch, OwnedServerName, OwnedUserId, RoomId, ServerName, UInt, UserId,
|
||||
};
|
||||
use tokio::{
|
||||
select,
|
||||
sync::{Mutex, Semaphore},
|
||||
};
|
||||
use tokio::sync::{Mutex, Semaphore};
|
||||
use tracing::{error, warn};
|
||||
|
||||
use crate::{services, utils::calculate_hash, Config, Error, PduEvent, Result};
|
||||
|
|
Loading…
Add table
Reference in a new issue