put process_streamed_group_message back

xmtp · Aug 21, 2024 · 803dd7a · 803dd7a
1 parent cde8e04
commit 803dd7a
Showing 1 changed file with 15 additions and 14 deletions.
diff --git a/xmtp_mls/src/groups/subscriptions.rs b/xmtp_mls/src/groups/subscriptions.rs
@@ -100,6 +100,21 @@ impl MlsGroup {
             .await?)
     }
 
+    pub async fn process_streamed_group_message<ApiClient>(
+        &self,
+        envelope_bytes: Vec<u8>,
+        client: Arc<Client<ApiClient>>,
+    ) -> Result<StoredGroupMessage, GroupError>
+    where
+        ApiClient: XmtpApi,
+    {
+        let envelope = GroupMessage::decode(envelope_bytes.as_slice())
+            .map_err(|e| GroupError::Generic(e.to_string()))?;
+
+        let message = self.process_stream_entry(envelope, client).await?;
+        message.ok_or(GroupError::MissingMessage)
+    }
+
     pub fn stream_with_callback<ApiClient>(
         client: Arc<Client<ApiClient>>,
         group_id: Vec<u8>,
@@ -121,20 +136,6 @@ impl MlsGroup {
             callback,
         )
     }
-    pub async fn process_streamed_group_message<ApiClient>(
-        &self,
-        envelope_bytes: Vec<u8>,
-        client: Arc<Client<ApiClient>>,
-    ) -> Result<StoredGroupMessage, GroupError>
-    where
-        ApiClient: XmtpApi,
-    {
-        let envelope = GroupMessage::decode(envelope_bytes.as_slice())
-            .map_err(|e| GroupError::Generic(e.to_string()))?;
-
-        let message = self.process_stream_entry(envelope, client).await?;
-        message.ok_or(GroupError::MissingMessage)
-    }
 }
 
 #[cfg(test)]