diff options
Diffstat (limited to 'tokio-util/src/codec/framed_read.rs')
-rw-r--r-- | tokio-util/src/codec/framed_read.rs | 9 |
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> |