Test output priority over progress

Author: hecrj

src/lib.rs

@@ -494,6 +494,7 @@ mod tests {
 
     use tokio::task;
     use tokio::test;
+    use tokio::time;
 
     #[derive(Debug, PartialEq, Eq)]
     struct File(Vec<u8>);
@@ -539,11 +540,13 @@ mod tests {
 
     #[test]
     async fn it_is_a_stream() {
-        assert!(download("https://iced.rs/logo.svg")
-            .collect::<Vec<_>>()
-            .await
-            .into_iter()
-            .eq(0..=100));
+        assert!(
+            download("https://iced.rs/logo.svg")
+                .collect::<Vec<_>>()
+                .await
+                .into_iter()
+                .eq(0..=100)
+        );
     }
 
     #[test]
@@ -555,11 +558,13 @@ mod tests {
         let progress = task::spawn(receiver.collect::<Vec<_>>());
         let file = download("https://iced.rs/logo.svg").run(sender).await;
 
-        assert!(progress
-            .await
-            .expect("Collect progress")
-            .into_iter()
-            .eq(0..=100));
+        assert!(
+            progress
+                .await
+                .expect("Collect progress")
+                .into_iter()
+                .eq(0..=100)
+        );
 
         assert_eq!(file, File(vec![1, 2, 3, 4]));
     }
@@ -713,4 +718,28 @@ mod tests {
         assert_eq!(i, 202);
         assert_eq!(files, vec![File(vec![1, 2, 3, 4]), File(vec![1, 2, 3, 4])]);
     }
+
+    #[test]
+    async fn it_prioritizes_output_over_progress() {
+        let mut infinite_progress = sipper(|progress| async move {
+            drop(task::spawn({
+                let mut progress = progress.clone();
+
+                async move {
+                    loop {
+                        progress.send(0).await;
+
+                        time::sleep(time::Duration::from_secs(1)).await;
+                    }
+                }
+            }));
+
+            true
+        })
+        .pin();
+
+        while infinite_progress.sip().await.is_some() {}
+
+        assert!(infinite_progress.await);
+    }
 }