// use tokio::sync::mpsc;
//
// type BitstampSubscription = String;
// type BitstampMessage = String;
//
// pub struct Bitstamp {
//     subscription_tx: mpsc::Sender<(BitstampSubscription, mpsc::UnboundedSender<BitstampMessage>)>,
// }