summaryrefslogtreecommitdiffstats
path: root/examples/connect.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/connect.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/connect.rs')
-rw-r--r--examples/connect.rs6
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 {