diff --git a/tarpc/examples/pubsub.rs b/tarpc/examples/pubsub.rs index f20e164..70f2a8d 100644 --- a/tarpc/examples/pubsub.rs +++ b/tarpc/examples/pubsub.rs @@ -186,6 +186,7 @@ async fn main() -> io::Result<()> { publisher .broadcast(context::current(), "hi again".to_string()) .await?; + drop(publisher); tokio::time::delay_for(Duration::from_millis(100)).await; println!("Done.");