summaryrefslogtreecommitdiffstats
path: root/tokio-io/src/codec/bytes_codec.rs
diff options
context:
space:
mode:
authorCarl Lerche <me@carllerche.com>2019-06-24 12:34:30 -0700
committerGitHub <noreply@github.com>2019-06-24 12:34:30 -0700
commit06c473e62842d257ed275497ce906710ea3f8e19 (patch)
tree4ca6d337a892aa23266a761b35dc61e988e57954 /tokio-io/src/codec/bytes_codec.rs
parentaa99950b9c983b842bd2107bb771c277d09d495d (diff)
Update Tokio to use `std::future`. (#1120)
A first pass at updating Tokio to use `std::future`. Implementations of `Future` from the futures crate are updated to implement `Future` from std. Implementations of `Stream` are moved to a feature flag. This commits disables a number of crates that have not yet been updated.
Diffstat (limited to 'tokio-io/src/codec/bytes_codec.rs')
-rw-r--r--tokio-io/src/codec/bytes_codec.rs42
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(())
- }
-}