+16 -4

attic/src/stream.rs

reviewed

··· 190 190 // force multiple reads 191 191 let mut buf = vec![0u8; 100]; 192 192 let mut bytes_read = 0; 193 193 - bytes_read += read.read(&mut buf[bytes_read..bytes_read + 5]).await.unwrap(); 194 194 - bytes_read += read.read(&mut buf[bytes_read..bytes_read + 5]).await.unwrap(); 195 195 - bytes_read += read.read(&mut buf[bytes_read..bytes_read + 5]).await.unwrap(); 196 196 - bytes_read += read.read(&mut buf[bytes_read..bytes_read + 5]).await.unwrap(); 193 193 + bytes_read += read 194 194 + .read(&mut buf[bytes_read..bytes_read + 5]) 195 195 + .await 196 196 + .unwrap(); 197 197 + bytes_read += read 198 198 + .read(&mut buf[bytes_read..bytes_read + 5]) 199 199 + .await 200 200 + .unwrap(); 201 201 + bytes_read += read 202 202 + .read(&mut buf[bytes_read..bytes_read + 5]) 203 203 + .await 204 204 + .unwrap(); 205 205 + bytes_read += read 206 206 + .read(&mut buf[bytes_read..bytes_read + 5]) 207 207 + .await 208 208 + .unwrap(); 197 209 198 210 assert_eq!(expected.len(), bytes_read); 199 211 assert_eq!(expected, &buf[..bytes_read]);

+1 -1

attic/src/testing/mod.rs

reviewed

··· 24 24 } 25 25 26 26 data 27 27 - } 27 27 + }

+1 -1

client/src/cache.rs

reviewed

··· 14 14 use anyhow::{anyhow, Result}; 15 15 use serde::{Deserialize, Serialize}; 16 16 17 17 - pub use attic::cache::{CacheName}; 17 17 + pub use attic::cache::CacheName; 18 18 19 19 /// A reference to a cache. 20 20 #[derive(Debug, Clone)]