summaryrefslogtreecommitdiffstats
path: root/buffered-reader/src/memory.rs
diff options
context:
space:
mode:
authorNeal H. Walfield <neal@pep.foundation>2018-01-01 22:31:27 +0100
committerNeal H. Walfield <neal@pep.foundation>2018-01-02 21:45:02 +0100
commit18f76fce2141a2db396bd914719918ffe92ea290 (patch)
treeb91f037f705b0f338a6330f87ed7e0c4c8a55ff5 /buffered-reader/src/memory.rs
parent9e8e5bf8f8e11b36164edda2473e112753e8101d (diff)
buffered_reader: Allow the user to store data in a BufferedReader.
- We want to associate some data with a BufferedReader instance. Because a BufferedReader points to another BufferedReader, we can't use a wrapper object. This change provides a mechanism to store any required data inside the actual `BufferedReader`. Note: this is a zero-cost abstraction. If no data needs to be stored, then there is no cost.
Diffstat (limited to 'buffered-reader/src/memory.rs')
-rw-r--r--buffered-reader/src/memory.rs43
1 files changed, 36 insertions, 7 deletions
diff --git a/buffered-reader/src/memory.rs b/buffered-reader/src/memory.rs
index 8d387c49..2bdc0eb2 100644
--- a/buffered-reader/src/memory.rs
+++ b/buffered-reader/src/memory.rs
@@ -7,13 +7,16 @@ use std::io::{Error,ErrorKind};
use super::*;
/// A `BufferedReader` specialized for reading from memory buffers.
-pub struct BufferedReaderMemory<'a> {
+pub struct BufferedReaderMemory<'a, C> {
buffer: &'a [u8],
// The next byte to read in the buffer.
cursor: usize,
+
+ // The user settable cookie.
+ cookie: C,
}
-impl <'a> fmt::Debug for BufferedReaderMemory<'a> {
+impl<'a, C> fmt::Debug for BufferedReaderMemory<'a, C> {
fn fmt(&self, f: &mut fmt::Formatter) -> fmt::Result {
f.debug_struct("BufferedReaderMemory")
.field("buffer (bytes)", &&self.buffer.len())
@@ -22,11 +25,23 @@ impl <'a> fmt::Debug for BufferedReaderMemory<'a> {
}
}
-impl<'a> BufferedReaderMemory<'a> {
- pub fn new(buffer: &'a [u8]) -> BufferedReaderMemory<'a> {
+impl<'a> BufferedReaderMemory<'a, ()> {
+ /// Instantiate a new memory-based reader. `buffer` contains the
+ /// reader's contents.
+ pub fn new(buffer: &'a [u8]) -> Self {
+ Self::with_cookie(buffer, ())
+ }
+}
+
+impl<'a, C> BufferedReaderMemory<'a, C> {
+ /// Like `new()`, but sets a cookie, which can be retrieved using
+ /// the `cookie_ref` and `cookie_mut` methods, and set using
+ /// the `cookie_set` method.
+ pub fn with_cookie(buffer: &'a [u8], cookie: C) -> Self {
BufferedReaderMemory {
buffer: buffer,
cursor: 0,
+ cookie: cookie,
}
}
@@ -37,7 +52,7 @@ impl<'a> BufferedReaderMemory<'a> {
}
}
-impl<'a> io::Read for BufferedReaderMemory<'a> {
+impl<'a, C> io::Read for BufferedReaderMemory<'a, C> {
fn read(&mut self, buf: &mut [u8]) -> Result<usize, io::Error> {
let amount = cmp::min(buf.len(), self.buffer.len() - self.cursor);
buf[0..amount].copy_from_slice(
@@ -47,7 +62,7 @@ impl<'a> io::Read for BufferedReaderMemory<'a> {
}
}
-impl<'a> BufferedReader for BufferedReaderMemory<'a> {
+impl<'a, C> BufferedReader<C> for BufferedReaderMemory<'a, C> {
/// Return the buffer. Ensure that it contains at least `amount`
/// bytes.
fn data(&mut self, _amount: usize) -> Result<&[u8], io::Error> {
@@ -77,10 +92,24 @@ impl<'a> BufferedReader for BufferedReaderMemory<'a> {
return Ok(self.consume(amount));
}
- fn into_inner<'b>(self: Box<Self>) -> Option<Box<BufferedReader + 'b>>
+ fn into_inner<'b>(self: Box<Self>) -> Option<Box<BufferedReader<C> + 'b>>
where Self: 'b {
None
}
+
+ fn cookie_set(&mut self, cookie: C) -> C {
+ use std::mem;
+
+ mem::replace(&mut self.cookie, cookie)
+ }
+
+ fn cookie_ref(&self) -> &C {
+ &self.cookie
+ }
+
+ fn cookie_mut(&mut self) -> &mut C {
+ &mut self.cookie
+ }
}
#[test]