remove with_value

Signed-off-by: Yashash H L <[email protected]>

numaflow/src/batchmap.rs

@@ -196,23 +196,6 @@ impl Message {
         self.tags = Some(tags);
         self
     }
-
-    /// Replaces the value of the message.
-    ///
-    /// # Arguments
-    ///
-    /// * `value` - A new vector of bytes that replaces the current message value.
-    ///
-    /// # Examples
-    ///
-    /// ```
-    /// use numaflow::batchmap::Message;
-    /// let message = Message::new(vec![1, 2, 3]).with_value(vec![4, 5, 6]);
-    /// ```
-    pub fn with_value(mut self, value: Vec<u8>) -> Self {
-        self.value = value;
-        self
-    }
 }
 /// The result of the call to [`BatchMapper::batchmap`] method.
 pub struct BatchResponse {

numaflow/src/map.rs

@@ -145,23 +145,6 @@ impl Message {
         self.tags = Some(tags);
         self
     }
-
-    /// Replaces the value of the message.
-    ///
-    /// # Arguments
-    ///
-    /// * `value` - A new vector of bytes that replaces the current message value.
-    ///
-    /// # Examples
-    ///
-    /// ```
-    /// use numaflow::map::Message;
-    /// let message = Message::new(vec![1, 2, 3]).with_value(vec![4, 5, 6]);
-    /// ```
-    pub fn with_value(mut self, value: Vec<u8>) -> Self {
-        self.value = value;
-        self
-    }
 }
 
 impl From<Message> for proto::map_response::Result {

numaflow/src/mapstream.rs

@@ -150,23 +150,6 @@ impl Message {
         self.tags = Some(tags);
         self
     }
-
-    /// Replaces the value of the message.
-    ///
-    /// # Arguments
-    ///
-    /// * `value` - A new vector of bytes that replaces the current message value.
-    ///
-    /// # Examples
-    ///
-    /// ```
-    /// use numaflow::mapstream::Message;
-    /// let message = Message::new(vec![1, 2, 3]).with_value(vec![4, 5, 6]);
-    /// ```
-    pub fn with_value(mut self, value: Vec<u8>) -> Self {
-        self.value = value;
-        self
-    }
 }
 
 impl From<Message> for proto::map_response::Result {
@@ -601,7 +584,7 @@ mod tests {
             async fn map_stream(&self, input: MapStreamRequest, tx: Sender<Message>) {
                 let message = Message::new(input.value)
                     .with_keys(input.keys)
-                    .with_value(vec![]);
+                    .with_tags(vec![]);
                 tx.send(message).await.unwrap();
             }
         }

numaflow/src/reduce.rs

@@ -259,23 +259,6 @@ impl Message {
         self.tags = Some(tags);
         self
     }
-
-    /// Replaces the value of the message.
-    ///
-    /// # Arguments
-    ///
-    /// * `value` - A new vector of bytes that replaces the current message value.
-    ///
-    /// # Examples
-    ///
-    /// ```
-    /// use numaflow::reduce::Message;
-    /// let message = Message::new(vec![1, 2, 3]).with_value(vec![4, 5, 6]);
-    /// ```
-    pub fn with_value(mut self, value: Vec<u8>) -> Self {
-        self.value = value;
-        self
-    }
 }
 
 /// Incoming request into the reducer handler of [`Reducer`].

numaflow/src/sourcetransform.rs

@@ -171,25 +171,6 @@ impl Message {
         self.tags = Some(tags);
         self
     }
-
-    /// Replaces the value of the message.
-    ///
-    /// # Arguments
-    ///
-    /// * `value` - A new vector of bytes that replaces the current message value.
-    ///
-    /// # Examples
-    ///
-    /// ```
-    /// use numaflow::sourcetransform::Message;
-    /// use chrono::Utc;
-    /// let now = Utc::now();
-    /// let message = Message::new(vec![1, 2, 3], now).with_value(vec![4, 5, 6]);
-    /// ```
-    pub fn with_value(mut self, value: Vec<u8>) -> Self {
-        self.value = value;
-        self
-    }
 }
 
 /// Incoming request to the Source Transformer.