Simplify implementation

yoshuawuyts · Sep 20, 2024 · 4093c89 · 4093c89
1 parent 224562a
commit 4093c89
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/src/concurrent_stream/from_concurrent_stream.rs b/src/concurrent_stream/from_concurrent_stream.rs
@@ -116,13 +116,13 @@ where
 
     async fn progress(self: Pin<&mut Self>) -> super::ConsumerState {
         let mut this = self.project();
+        let Ok(items) = this.output else {
+            return ConsumerState::Break;
+        };
 
         while let Some(item) = this.group.next().await {
             match item {
                 Ok(item) => {
-                    let Ok(items) = this.output else {
-                        panic!("progress called after returning ConsumerState::Break");
-                    };
                     items.push(item);
                 }
                 Err(e) => {