//! Piping messages around
use super::*;
use futures::Future;

pub mod pubsub;

pub fn pass_messages()