summaryrefslogtreecommitdiffstats
path: root/examples/print_each_packet.rs
diff options
context:
space:
mode:
authorBryan Burgers <bryan@burgers.io>2018-06-04 22:36:06 -0500
committerCarl Lerche <me@carllerche.com>2018-06-04 20:36:06 -0700
commitf723d100871e025e4bdd2f47397c9b089e666ce0 (patch)
tree7d67d7f8bee561f6f04b9d1222dd02719fb47b12 /examples/print_each_packet.rs
parent3d7263d3a0b73ab35d63b45a6524bde7251851e8 (diff)
Create tokio-codec (#360)
Create a new tokio-codec crate with many of the contents of `tokio_io::codec`.
Diffstat (limited to 'examples/print_each_packet.rs')
-rw-r--r--examples/print_each_packet.rs7
1 files changed, 4 insertions, 3 deletions
diff --git a/examples/print_each_packet.rs b/examples/print_each_packet.rs
index bb054948..5dc53324 100644
--- a/examples/print_each_packet.rs
+++ b/examples/print_each_packet.rs
@@ -55,9 +55,10 @@
#![deny(warnings)]
extern crate tokio;
+extern crate tokio_codec;
extern crate tokio_io;
-use tokio_io::codec::BytesCodec;
+use tokio_codec::{Decoder, BytesCodec};
use tokio::net::TcpListener;
use tokio::prelude::*;
@@ -99,8 +100,8 @@ fn main() {
// We're parsing each socket with the `BytesCodec` included in `tokio_io`,
// and then we `split` each codec into the reader/writer halves.
//
- // See https://docs.rs/tokio-io/0.1/src/tokio_io/codec/bytes_codec.rs.html
- let framed = socket.framed(BytesCodec::new());
+ // See https://docs.rs/tokio-codec/0.1/src/tokio_codec/bytes_codec.rs.html
+ let framed = BytesCodec::new().framed(socket);
let (_writer, reader) = framed.split();
let processor = reader