mirror of
https://github.com/OMGeeky/tarpc.git
synced 2025-12-30 16:18:56 +01:00
Workaround for pubsub example hanging.
The publisher client isn't being dropped when the async fn returns. It could potentially be something strange in the ThreadPool executor.
This commit is contained in:
@@ -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.");
|
||||
|
||||
Reference in New Issue
Block a user