diff options
author | Bryan Burgers <bryan@burgers.io> | 2018-06-04 22:36:06 -0500 |
---|---|---|
committer | Carl Lerche <me@carllerche.com> | 2018-06-04 20:36:06 -0700 |
commit | f723d100871e025e4bdd2f47397c9b089e666ce0 (patch) | |
tree | 7d67d7f8bee561f6f04b9d1222dd02719fb47b12 /examples/connect.rs | |
parent | 3d7263d3a0b73ab35d63b45a6524bde7251851e8 (diff) |
Create tokio-codec (#360)
Create a new tokio-codec crate with many of the contents of
`tokio_io::codec`.
Diffstat (limited to 'examples/connect.rs')
-rw-r--r-- | examples/connect.rs | 6 |
1 files changed, 4 insertions, 2 deletions
diff --git a/examples/connect.rs b/examples/connect.rs index f44a5c1e..5a6b5151 100644 --- a/examples/connect.rs +++ b/examples/connect.rs @@ -17,6 +17,7 @@ #![deny(warnings)] extern crate tokio; +extern crate tokio_codec; extern crate tokio_io; extern crate futures; extern crate bytes; @@ -82,7 +83,7 @@ fn main() { mod codec { use std::io; use bytes::{BufMut, BytesMut}; - use tokio_io::codec::{Encoder, Decoder}; + use tokio_codec::{Encoder, Decoder}; /// A simple `Codec` implementation that just ships bytes around. /// @@ -120,6 +121,7 @@ mod codec { mod tcp { use tokio; + use tokio_codec::Decoder; use tokio::net::TcpStream; use tokio::prelude::*; @@ -151,7 +153,7 @@ mod tcp { // to the TCP stream. This is done to ensure that happens concurrently // with us reading data from the stream. Box::new(tcp.map(move |stream| { - let (sink, stream) = stream.framed(Bytes).split(); + let (sink, stream) = Bytes.framed(stream).split(); tokio::spawn(stdin.forward(sink).then(|result| { if let Err(e) = result { |