fix process result value

nttcom · Jan 14, 2025 · 1510124 · 1510124
1 parent c54bcb7
commit 1510124
Showing 1 changed file with 2 additions and 8 deletions.
diff --git a/moqt-server/src/modules/message_handlers/stream_header.rs b/moqt-server/src/modules/message_handlers/stream_header.rs
@@ -104,10 +104,7 @@ pub async fn try_read_header(
                     tracing::warn!("{:#?}", err);
                     // Reset the cursor position because data for the header has not yet arrived
                     buf.advance(read_cur.position() as usize);
-                    StreamHeaderProcessResult::Failure(
-                        TerminationErrorCode::InternalError,
-                        err.to_string(),
-                    )
+                    StreamHeaderProcessResult::Continue
                 }
             }
         }
@@ -124,10 +121,7 @@ pub async fn try_read_header(
                     tracing::warn!("{:#?}", err);
                     // Reset the cursor position because data for the header has not yet arrived
                     buf.advance(read_cur.position() as usize);
-                    StreamHeaderProcessResult::Failure(
-                        TerminationErrorCode::InternalError,
-                        err.to_string(),
-                    )
+                    StreamHeaderProcessResult::Continue
                 }
             }
         }