io-context 0.2.0

A context that carries a deadline, cancelation signals and request scoped values across API boundaries and between processes.
Documentation 
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

// Copyright 2017 Thomas de Zeeuw
//
// Licensed under the Apache License, Version 2.0 <LICENSE-APACHE or
// http://www.apache.org/licenses/LICENSE-2.0> or the MIT license <LICENSE-MIT
// or http://opensource.org/licenses/MIT>, at your option. This file may not be
// used, copied, modified, or distributed except according to those terms.

#[cfg(feature = "context-future")]
extern crate futures;
extern crate io_context;

#[cfg(feature = "context-future")]
fn main() {
    use io_context::{Context, ContextFuture, DoneReason};
    use futures::{Future, Async};
    use futures::future::poll_fn;

    let mut ctx = Context::background();
    let cancel_signal = ctx.add_cancel_signal();

    let future = poll_fn::<(), DoneReason, _>(|| {
        println!("future called!");
        Ok(Async::Ready(()))
    });

    let wrapper_future = ContextFuture::new_future(ctx, future);
    cancel_signal.cancel();

    match wrapper_future.wait() {
        Ok(()) => panic!("future completed unexpectedly"),
        Err(err) => println!("error calling future: {}", err),
    }
}

#[cfg(not(feature = "context-future"))]
fn main() {
    panic!("enable the `context-future` feature, by running `--features context-future`");
}