Rename Reader to BlobReader

Author: rklaehn

src/api/blobs.rs

@@ -33,7 +33,7 @@ use serde::{Deserialize, Serialize};
 use tokio::io::AsyncWriteExt;
 use tracing::trace;
 mod reader;
-pub use reader::Reader;
+pub use reader::BlobReader;
 
 // Public reexports from the proto module.
 //
@@ -105,12 +105,12 @@ impl Blobs {
         })
     }
 
-    pub fn reader(&self, hash: impl Into<Hash>) -> Reader {
+    pub fn reader(&self, hash: impl Into<Hash>) -> BlobReader {
         self.reader_with_opts(ReaderOptions { hash: hash.into() })
     }
 
-    pub fn reader_with_opts(&self, options: ReaderOptions) -> Reader {
-        Reader::new(self.clone(), options)
+    pub fn reader_with_opts(&self, options: ReaderOptions) -> BlobReader {
+        BlobReader::new(self.clone(), options)
     }
 
     /// Delete a blob.

src/api/blobs/reader.rs

@@ -12,7 +12,7 @@ use crate::api::{
 };
 
 #[derive(Debug)]
-pub struct Reader {
+pub struct BlobReader {
     blobs: Blobs,
     options: ReaderOptions,
     state: ReaderState,
@@ -35,7 +35,7 @@ enum ReaderState {
     Poisoned,
 }
 
-impl Reader {
+impl BlobReader {
     pub fn new(blobs: Blobs, options: ReaderOptions) -> Self {
         Self {
             blobs,
@@ -45,7 +45,7 @@ impl Reader {
     }
 }
 
-impl tokio::io::AsyncRead for Reader {
+impl tokio::io::AsyncRead for BlobReader {
     fn poll_read(
         self: Pin<&mut Self>,
         cx: &mut Context<'_>,
@@ -143,7 +143,7 @@ impl tokio::io::AsyncRead for Reader {
     }
 }
 
-impl tokio::io::AsyncSeek for Reader {
+impl tokio::io::AsyncSeek for BlobReader {
     fn start_seek(
         self: std::pin::Pin<&mut Self>,
         seek_from: tokio::io::SeekFrom,