Rename ObjectStreamProcessResult::IncompleteMessage to Continue

moqt-server/src/modules/message_handlers/object_datagram.rs

@@ -14,7 +14,7 @@ use tokio::sync::Mutex;
 #[derive(Debug, PartialEq)]
 pub enum ObjectDatagramProcessResult {
     Success(ObjectDatagram),
-    IncompleteMessage,
+    Continue,
     Failure(TerminationErrorCode, String),
 }
 
@@ -49,7 +49,7 @@ pub(crate) async fn try_read_object(
 
     // Check if the data is exist
     if payload_length == 0 {
-        return ObjectDatagramProcessResult::IncompleteMessage;
+        return ObjectDatagramProcessResult::Continue;
     }
 
     // check subscription and judge if it is invalid timing
@@ -92,7 +92,7 @@ pub(crate) async fn try_read_object(
                     tracing::warn!("{:#?}", err);
                     // Reset the cursor position because data for an object has not yet arrived
                     read_cur.set_position(0);
-                    ObjectDatagramProcessResult::IncompleteMessage
+                    ObjectDatagramProcessResult::Continue
                 }
             }
         }

moqt-server/src/modules/message_handlers/object_stream.rs

@@ -12,7 +12,7 @@ use std::io::Cursor;
 #[derive(Debug, PartialEq)]
 pub enum ObjectStreamProcessResult {
     Success(StreamObject),
-    IncompleteMessage,
+    Continue,
     Failure(TerminationErrorCode, String),
 }
 
@@ -31,7 +31,7 @@ pub async fn try_read_object(
 
     // Check if the data is exist
     if payload_length == 0 {
-        return ObjectStreamProcessResult::IncompleteMessage;
+        return ObjectStreamProcessResult::Continue;
     }
 
     let mut read_cur = Cursor::new(&buf[..]);
@@ -51,7 +51,7 @@ pub async fn try_read_object(
                     // Reset the cursor position because data for an object has not yet arrived
                     read_cur.set_position(0);
 
-                    ObjectStreamProcessResult::IncompleteMessage
+                    ObjectStreamProcessResult::Continue
                 }
             }
         }
@@ -69,7 +69,7 @@ pub async fn try_read_object(
                     // // Reset the cursor position because data for an object has not yet arrived
                     read_cur.set_position(0);
 
-                    ObjectStreamProcessResult::IncompleteMessage
+                    ObjectStreamProcessResult::Continue
                 }
             }
         }

moqt-server/src/modules/message_handlers/stream_header.rs

@@ -18,7 +18,7 @@ use tokio::sync::Mutex;
 #[derive(Debug, PartialEq)]
 pub enum StreamHeaderProcessResult {
     Success(StreamHeader),
-    IncompleteMessage,
+    Continue,
     Failure(TerminationErrorCode, String),
 }
 
@@ -59,7 +59,7 @@ pub async fn try_read_header(
 
     // Check if the data stream type is exist
     if payload_length == 0 {
-        return StreamHeaderProcessResult::IncompleteMessage;
+        return StreamHeaderProcessResult::Continue;
     }
 
     // check subscription and judge if it is invalid timing

moqt-server/src/modules/server_processes/stream_and_datagram/datagram/receiver.rs

@@ -98,7 +98,7 @@ impl DatagramReceiver {
 
         match result {
             ObjectDatagramProcessResult::Success(datagram_object) => Ok(Some(datagram_object)),
-            ObjectDatagramProcessResult::IncompleteMessage => Ok(None),
+            ObjectDatagramProcessResult::Continue => Ok(None),
             ObjectDatagramProcessResult::Failure(code, reason) => {
                 let msg = std::format!("object_stream_read failure: {:?}", reason);
                 tracing::error!(msg);

moqt-server/src/modules/server_processes/stream_and_datagram/uni_directional_stream/receiver.rs

@@ -179,7 +179,7 @@ impl UniStreamReceiver {
 
         match result {
             StreamHeaderProcessResult::Success(stream_header) => Ok(Some(stream_header)),
-            StreamHeaderProcessResult::IncompleteMessage => Ok(None),
+            StreamHeaderProcessResult::Continue => Ok(None),
             StreamHeaderProcessResult::Failure(code, reason) => {
                 let msg = std::format!("stream_header_read failure: {:?}", reason);
                 Err((code, msg))
@@ -433,7 +433,7 @@ impl UniStreamReceiver {
 
         match result {
             ObjectStreamProcessResult::Success(stream_object) => Ok(Some(stream_object)),
-            ObjectStreamProcessResult::IncompleteMessage => Ok(None),
+            ObjectStreamProcessResult::Continue => Ok(None),
             ObjectStreamProcessResult::Failure(code, reason) => {
                 let msg = std::format!("object_stream_read failure: {:?}", reason);
                 Err((code, msg))