diff options
author | Kornel <kornel@geekhood.net> | 2020-03-01 15:54:23 +0000 |
---|---|---|
committer | Kornel <kornel@geekhood.net> | 2020-03-01 22:14:40 +0000 |
commit | 01ad124c4872ed24751d5c36a8444bddbc4a4a64 (patch) | |
tree | 66c44047fb79f03b3ac45a7ccf5fabf0667d61e5 /simple_cache | |
parent | a38758e88c390600fef6a2eda243296bf8a198f6 (diff) |
fmt
Diffstat (limited to 'simple_cache')
-rw-r--r-- | simple_cache/src/db.rs | 14 | ||||
-rw-r--r-- | simple_cache/src/kv.rs | 6 |
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 { |