thread::spawn(move || {
        info!("Let's print each bundle.");
        let aggregator = rx.for_each(move |bundle| {
                info!("bundle contents {:?}", bundle);
                Ok(()) as Result<(), ()>
            })
            .into_future();
        remote.spawn(|_| {
            info!("spawning on remote");
            aggregator.then(|_| {
                info!("aggregator finished its run");
                Ok(()) as Result<(), ()>
            })
        })
    });