mirrors/buzzrelay
1
0
Fork 0
mirror of https://github.com/astro/buzzrelay.git synced 2024-11-21 19:51:00 +00:00
Code Issues Projects Releases Packages Wiki Activity

update dependencies

Browse source
This commit is contained in:
Astro 2024-10-04 01:13:16 +02:00
parent feca0fc0cb
commit 46550ac044
2 changed files with 279 additions and 250 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

521
Cargo.lock generated
View file

File diff suppressed because it is too large Load diff

8
src/stream.rs
View file

@ -55,8 +55,12 @@ pub fn spawn(hosts: impl Iterator<Item = impl Into<String>>) -> Receiver<String>
stream.for_each(|post| async { stream.for_each(|post| async {
tx.send(post).await.unwrap(); tx.send(post).await.unwrap();
}).await, }).await,
Err(e) => Err(StreamError::Http(e)) =>
tracing::error!("stream: {:?}", e), tracing::error!("stream http error: {:?}", e),
Err(StreamError::HttpStatus(status)) =>
tracing::error!("stream http status: {:?}", status),
Err(StreamError::InvalidContentType) =>
tracing::error!("stream invalid content-type"),
} }
sleep(Duration::from_secs(1)).await; sleep(Duration::from_secs(1)).await;