diff options
Diffstat (limited to 'tokio-io/src/codec/bytes_codec.rs')
-rw-r--r-- | tokio-io/src/codec/bytes_codec.rs | 42 |
1 files changed, 0 insertions, 42 deletions
diff --git a/tokio-io/src/codec/bytes_codec.rs b/tokio-io/src/codec/bytes_codec.rs deleted file mode 100644 index 66369478..00000000 --- a/tokio-io/src/codec/bytes_codec.rs +++ /dev/null @@ -1,42 +0,0 @@ -#![allow(deprecated)] - -use crate::codec::{Decoder, Encoder}; -use bytes::{BufMut, Bytes, BytesMut}; -use std::io; - -/// A simple `Codec` implementation that just ships bytes around. -#[derive(Copy, Clone, Debug, Eq, PartialEq, Ord, PartialOrd, Hash)] -#[deprecated(since = "0.1.7", note = "Moved to tokio-codec")] -pub struct BytesCodec(()); - -impl BytesCodec { - /// Creates a new `BytesCodec` for shipping around raw bytes. - pub fn new() -> BytesCodec { - BytesCodec(()) - } -} - -impl Decoder for BytesCodec { - type Item = BytesMut; - type Error = io::Error; - - fn decode(&mut self, buf: &mut BytesMut) -> Result<Option<BytesMut>, io::Error> { - if buf.len() > 0 { - let len = buf.len(); - Ok(Some(buf.split_to(len))) - } else { - Ok(None) - } - } -} - -impl Encoder for BytesCodec { - type Item = Bytes; - type Error = io::Error; - - fn encode(&mut self, data: Bytes, buf: &mut BytesMut) -> Result<(), io::Error> { - buf.reserve(data.len()); - buf.put(data); - Ok(()) - } -} |