Wait for the tasks using join_all

async-message-passing/src/main.rs

@@ -1,4 +1,4 @@
-use std::time::Duration;
+use std::{pin::Pin, time::Duration};
 
 fn main() {
     trpl::run(async {
@@ -39,6 +39,9 @@ fn main() {
             }
         };
 
-        trpl::join!(tx1_fut, tx_fut, rx_fut);
+        let futures: Vec<Pin<Box<dyn Future<Output = ()>>>> =
+            vec![Box::pin(tx1_fut), Box::pin(rx_fut), Box::pin(tx_fut)];
+
+        trpl::join_all(futures).await;
     });
 }