nostr/gossip
1
0
Fork 0
mirror of https://github.com/mikedilger/gossip.git synced 2024-09-19 19:46:50 +00:00
Code Issues Packages Projects Releases Wiki Activity

Fix RIF count

Browse Source
This commit is contained in:
Mike Dilger 2023-01-04 17:25:42 +13:00
parent 050780cc87
commit c216a0b5c1
1 changed files with 13 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

15
src/fetcher.rs
View File

@ -150,16 +150,27 @@ impl Fetcher {
let maybe_response = client.get(url.inner()).timeout(timeout).send().await; let maybe_response = client.get(url.inner()).timeout(timeout).send().await;
// Deal with response errors // Deal with response errors
let response = maybe_response?; let response = match maybe_response {
Ok(r) => r,
Err(e) => {
GLOBALS
.fetcher
.requests_in_flight
.fetch_sub(1, Ordering::SeqCst);
return Err(e.into());
}
};
// Convert to bytes // Convert to bytes
let bytes = response.bytes().await?; let maybe_bytes = response.bytes().await;
GLOBALS GLOBALS
.fetcher .fetcher
.requests_in_flight .requests_in_flight
.fetch_sub(1, Ordering::SeqCst); .fetch_sub(1, Ordering::SeqCst);
let bytes = maybe_bytes?;
let cache_file = GLOBALS.fetcher.cache_file(&url); let cache_file = GLOBALS.fetcher.cache_file(&url);
// Write to the file // Write to the file