Reexport Encoder, Decoder, Framed* from tokio::codec (#499)

This commit is contained in:
Roman
2018-08-14 11:18:54 -07:00
committed by Carl Lerche
parent 31f71dedee
commit 2e343f9e42
5 changed files with 30 additions and 10 deletions
+1 -2
View File
@@ -42,6 +42,7 @@ travis-ci = { repository = "tokio-rs/tokio" }
appveyor = { repository = "carllerche/tokio", id = "s83yxhy9qeb58va7" } appveyor = { repository = "carllerche/tokio", id = "s83yxhy9qeb58va7" }
[dependencies] [dependencies]
tokio-codec = { version = "0.1.0", path = "tokio-codec" }
tokio-current-thread = { version = "0.1.0", path = "tokio-current-thread" } tokio-current-thread = { version = "0.1.0", path = "tokio-current-thread" }
tokio-io = { version = "0.1.6", path = "tokio-io" } tokio-io = { version = "0.1.6", path = "tokio-io" }
tokio-executor = { version = "0.1.2", path = "tokio-executor" } tokio-executor = { version = "0.1.2", path = "tokio-executor" }
@@ -58,8 +59,6 @@ futures = "0.1.20"
mio = "0.6.14" mio = "0.6.14"
[dev-dependencies] [dev-dependencies]
tokio-codec = { version = "0.1.0", path = "tokio-codec" }
bytes = "0.4" bytes = "0.4"
env_logger = { version = "0.5", default-features = false } env_logger = { version = "0.5", default-features = false }
flate2 = { version = "1", features = ["tokio"] } flate2 = { version = "1", features = ["tokio"] }
+2 -3
View File
@@ -17,7 +17,6 @@
#![deny(warnings)] #![deny(warnings)]
extern crate tokio; extern crate tokio;
extern crate tokio_codec;
extern crate tokio_io; extern crate tokio_io;
extern crate futures; extern crate futures;
extern crate bytes; extern crate bytes;
@@ -83,7 +82,7 @@ fn main() {
mod codec { mod codec {
use std::io; use std::io;
use bytes::{BufMut, BytesMut}; use bytes::{BufMut, BytesMut};
use tokio_codec::{Encoder, Decoder}; use tokio::codec::{Encoder, Decoder};
/// A simple `Codec` implementation that just ships bytes around. /// A simple `Codec` implementation that just ships bytes around.
/// ///
@@ -121,9 +120,9 @@ mod codec {
mod tcp { mod tcp {
use tokio; use tokio;
use tokio_codec::Decoder;
use tokio::net::TcpStream; use tokio::net::TcpStream;
use tokio::prelude::*; use tokio::prelude::*;
use tokio::codec::Decoder;
use bytes::BytesMut; use bytes::BytesMut;
use codec::Bytes; use codec::Bytes;
+2 -2
View File
@@ -56,11 +56,11 @@
extern crate tokio; extern crate tokio;
extern crate tokio_codec; extern crate tokio_codec;
extern crate tokio_io;
use tokio_codec::{Decoder, BytesCodec}; use tokio_codec::BytesCodec;
use tokio::net::TcpListener; use tokio::net::TcpListener;
use tokio::prelude::*; use tokio::prelude::*;
use tokio::codec::Decoder;
use std::env; use std::env;
use std::net::SocketAddr; use std::net::SocketAddr;
+1 -3
View File
@@ -21,7 +21,6 @@ extern crate serde_derive;
extern crate serde_json; extern crate serde_json;
extern crate time; extern crate time;
extern crate tokio; extern crate tokio;
extern crate tokio_codec;
extern crate tokio_io; extern crate tokio_io;
use std::{env, fmt, io}; use std::{env, fmt, io};
@@ -29,8 +28,7 @@ use std::net::SocketAddr;
use tokio::net::{TcpStream, TcpListener}; use tokio::net::{TcpStream, TcpListener};
use tokio::prelude::*; use tokio::prelude::*;
use tokio::codec::{Encoder, Decoder};
use tokio_codec::{Encoder, Decoder};
use bytes::BytesMut; use bytes::BytesMut;
use http::header::HeaderValue; use http::header::HeaderValue;
+24
View File
@@ -73,6 +73,7 @@ extern crate mio;
extern crate tokio_current_thread; extern crate tokio_current_thread;
extern crate tokio_io; extern crate tokio_io;
extern crate tokio_executor; extern crate tokio_executor;
extern crate tokio_codec;
extern crate tokio_fs; extern crate tokio_fs;
extern crate tokio_reactor; extern crate tokio_reactor;
extern crate tokio_threadpool; extern crate tokio_threadpool;
@@ -92,6 +93,29 @@ pub mod util;
pub use executor::spawn; pub use executor::spawn;
pub use runtime::run; pub use runtime::run;
pub mod codec {
//! Utilities for encoding and decoding frames.
//!
//! Contains adapters to go from streams of bytes, [`AsyncRead`] and
//! [`AsyncWrite`], to framed streams implementing [`Sink`] and [`Stream`].
//! Framed streams are also known as [transports].
//!
//! [`AsyncRead`]: #
//! [`AsyncWrite`]: #
//! [`Sink`]: #
//! [`Stream`]: #
//! [transports]: #
pub use tokio_codec::{
Decoder,
Encoder,
Framed,
FramedParts,
FramedRead,
FramedWrite,
};
}
pub mod io { pub mod io {
//! Asynchronous I/O. //! Asynchronous I/O.
//! //!