diff --git a/examples/pubsub.rs b/examples/pubsub.rs index aa23a4e..be438b0 100644 --- a/examples/pubsub.rs +++ b/examples/pubsub.rs @@ -100,7 +100,7 @@ impl publisher::FutureService for Publisher { type SubscribeFut = Box>; fn subscribe(&self, id: u32, address: SocketAddr) -> Self::SubscribeFut { - let clients = self.clients.clone(); + let clients = Rc::clone(&self.clients); Box::new( subscriber::FutureClient::connect(address, client::Options::default()) .map(move |subscriber| {