steffo/todocolors
steffo/todocolors
1
Fork 0
mirror of https://github.com/Steffo99/todocolors.git synced 2024-11-22 08:14:18 +00:00
Code Activity

Increase XREAD BLOCK time to 60000 ms

Browse source
This commit is contained in:
Steffo 2023-08-04 03:25:05 +02:00
parent baac11c3ea
commit 2d1522b9b7
Signed by: steffo
GPG key ID: 2A24051445686895
1 changed files with 2 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

4
todored/src/routes/board/redis_xread.rs
View file

@ -15,11 +15,11 @@ pub async fn handler(
let mut seq = "0".to_string(); let mut seq = "0".to_string();
loop { loop {
log::trace!("Waiting for events to broadcast for 5 seconds..."); log::trace!("Waiting for events to broadcast for 60 seconds...");
let response: RedisResult<StreamReadReply> = rconn.xread_options( let response: RedisResult<StreamReadReply> = rconn.xread_options(
&[&key], &[&key],
&[&seq], &[&seq],
&StreamReadOptions::default().block(5000) &StreamReadOptions::default().block(60000)
).await; ).await;
match response { match response {