summaryrefslogtreecommitdiffstats
path: root/tokio-util/src/codec/framed_read.rs
diff options
context:
space:
mode:
Diffstat (limited to 'tokio-util/src/codec/framed_read.rs')
-rw-r--r--tokio-util/src/codec/framed_read.rs9
1 files changed, 9 insertions, 0 deletions
diff --git a/tokio-util/src/codec/framed_read.rs b/tokio-util/src/codec/framed_read.rs
index 6f79cb9a..e10f2968 100644
--- a/tokio-util/src/codec/framed_read.rs
+++ b/tokio-util/src/codec/framed_read.rs
@@ -79,6 +79,11 @@ impl<T, D> FramedRead<T, D> {
pub fn decoder_mut(&mut self) -> &mut D {
&mut self.inner.inner.1
}
+
+ /// Returns a reference to the read buffer.
+ pub fn read_buffer(&self) -> &BytesMut {
+ &self.inner.buffer
+ }
}
impl<T, D> Stream for FramedRead<T, D>
@@ -174,6 +179,10 @@ impl<T> FramedRead2<T> {
pub(crate) fn get_mut(&mut self) -> &mut T {
&mut self.inner
}
+
+ pub(crate) fn buffer(&self) -> &BytesMut {
+ &self.buffer
+ }
}
impl<T> Stream for FramedRead2<T>