Advertisement
Guest User

Untitled

a guest
Mar 17th, 2017
59
0
Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
Rust 0.22 KB | None | 0 0
  1. let aggregator = rx.map(move |bundle| {
  2.             info!("bundle contents {:?}", bundle);
  3.             Ok(()) as Result<(), ()>
  4.         })
  5.         .collect()
  6.         .into_future();
  7.     assert!(core.run(aggregator).is_ok());
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement