1
 2
 3
 4
 5
 6
 7
 8
 9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65

extern crate tokio;
#[macro_use]
extern crate futures;
extern crate void;
#[macro_use]
extern crate log;
#[macro_use]
extern crate unwrap;
extern crate bytes;

use std::io;
use futures::{Future, Stream, Sink};

mod drop_notify;
mod until;
mod future_ext;
mod stream_ext;
mod first_ok;
mod log_errors;
mod log_error;
mod infallible;
mod next_or_else;
mod finally;
mod delay;
mod with_timeout;
mod thread_future;
mod first_ok2;
mod while_driving;
mod resume_unwind;
mod with_readiness_timeout;
pub mod bi_channel;
pub mod mpsc;
mod framed_unbuffered;

pub use drop_notify::{drop_notify, DropNotify, DropNotice};
pub use until::Until;
pub use first_ok::FirstOk;
pub use log_errors::LogErrors;
pub use log_error::LogError;
pub use future_ext::FutureExt;
pub use stream_ext::StreamExt;
pub use infallible::Infallible;
pub use next_or_else::NextOrElse;
pub use finally::Finally;
pub use with_timeout::WithTimeout;
pub use delay::Delay;
pub use with_readiness_timeout::WithReadinessTimeout;
pub use thread_future::{thread_future, ThreadFuture};
pub use first_ok2::FirstOk2;
pub use while_driving::{WhileDriving, Finish, FinishInner};
pub use resume_unwind::ResumeUnwind;
pub use framed_unbuffered::FramedUnbuffered;

pub type BoxFuture<T, E> = Box<Future<Item=T, Error=E>>;
pub type BoxStream<T, E> = Box<Stream<Item=T, Error=E>>;
pub type BoxSink<T, E> = Box<Sink<SinkItem=T, SinkError=E>>;

pub type BoxSendFuture<T, E> = Box<Future<Item=T, Error=E> + Send>;
pub type BoxSendStream<T, E> = Box<Stream<Item=T, Error=E> + Send>;
pub type BoxSendSink<T, E> = Box<Sink<SinkItem=T, SinkError=E> + Send>;

pub type IoFuture<T> = Box<Future<Item=T, Error=io::Error>>;
pub type IoStream<T> = Box<Stream<Item=T, Error=io::Error>>;
pub type IoSink<T> = Box<Sink<SinkItem=T, SinkError=io::Error>>;