pub fn subscribe<T, F>( topic: &str, queue_size: usize, callback: F, ) -> Result<Subscriber>where T: Message, F: Fn(T) + Send + 'static,