diff options
Diffstat (limited to 'examples/events.rs')
-rw-r--r-- | examples/events.rs | 14 |
1 files changed, 11 insertions, 3 deletions
diff --git a/examples/events.rs b/examples/events.rs index f1518d3..ced2f29 100644 --- a/examples/events.rs +++ b/examples/events.rs @@ -1,11 +1,19 @@ extern crate shiplift; +extern crate tokio; use shiplift::Docker; +use tokio::prelude::{Future, Stream}; fn main() { let docker = Docker::new(); println!("listening for events"); - for e in docker.events(&Default::default()).unwrap() { - println!("event -> {:?}", e) - } + + let fut = docker + .events(&Default::default()) + .for_each(|e| { + println!("event -> {:?}", e); + Ok(()) + }) + .map_err(|e| eprintln!("Error: {}", e)); + tokio::run(fut); } |