summaryrefslogtreecommitdiffstats
path: root/simple_cache
diff options
context:
space:
mode:
authorKornel <kornel@geekhood.net>2020-03-01 15:54:23 +0000
committerKornel <kornel@geekhood.net>2020-03-01 22:14:40 +0000
commit01ad124c4872ed24751d5c36a8444bddbc4a4a64 (patch)
tree66c44047fb79f03b3ac45a7ccf5fabf0667d61e5 /simple_cache
parenta38758e88c390600fef6a2eda243296bf8a198f6 (diff)
fmt
Diffstat (limited to 'simple_cache')
-rw-r--r--simple_cache/src/db.rs14
-rw-r--r--simple_cache/src/kv.rs6
2 files changed, 10 insertions, 10 deletions
diff --git a/simple_cache/src/db.rs b/simple_cache/src/db.rs
index 13cafaa..b8a6b78 100644
--- a/simple_cache/src/db.rs
+++ b/simple_cache/src/db.rs
@@ -129,12 +129,12 @@ impl SimpleCache {
}
pub(crate) async fn fetch(url: &str) -> Result<Vec<u8>, Error> {
- println!("REQ {}", url);
- let client = reqwest::Client::builder().build()?;
- let res = client.get(url).header(reqwest::header::USER_AGENT, "crates.rs/1.0").send().await?;
- if res.status() != reqwest::StatusCode::OK {
- Err(res.status())?;
- }
- Ok(res.bytes().await?.to_vec())
+ println!("REQ {}", url);
+ let client = reqwest::Client::builder().build()?;
+ let res = client.get(url).header(reqwest::header::USER_AGENT, "crates.rs/1.0").send().await?;
+ if res.status() != reqwest::StatusCode::OK {
+ Err(res.status())?;
+ }
+ Ok(res.bytes().await?.to_vec())
}
}
diff --git a/simple_cache/src/kv.rs b/simple_cache/src/kv.rs
index 5e57110..2e15f88 100644
--- a/simple_cache/src/kv.rs
+++ b/simple_cache/src/kv.rs
@@ -1,4 +1,3 @@
-use std::hash::Hash;
use crate::error::Error;
use crate::SimpleCache;
use flate2::read::DeflateDecoder;
@@ -12,13 +11,14 @@ use serde::de::DeserializeOwned;
use serde::*;
use serde_json;
use std::borrow::Borrow;
+use std::collections::hash_map::Entry;
use std::fs::File;
+use std::hash::Hash;
use std::io::BufReader;
use std::io::BufWriter;
use std::marker::PhantomData;
use std::path::PathBuf;
use tempfile::NamedTempFile;
-use std::collections::hash_map::Entry;
type FxHashMap<K, V> = std::collections::HashMap<K, V, ahash::RandomState>;
@@ -106,7 +106,7 @@ impl<T: Serialize + DeserializeOwned + Clone + Send, K: Serialize + DeserializeO
return Ok(());
}
e.insert(compr);
- }
+ },
}
w.writes += 1;
if w.writes >= w.next_autosave {