adds tests for it

Author: nplasterer

library/src/androidTest/java/org/xmtp/android/library/GroupTest.kt

@@ -320,6 +320,31 @@ class GroupTest {
         }
     }
 
+    @Test
+    fun testCanStreamAllGroupMessages() = kotlinx.coroutines.test.runTest {
+        val group = caroClient.conversations.newGroup(listOf(alix.walletAddress))
+        alixClient.conversations.syncGroups()
+        alixClient.conversations.streamAllGroupMessages().test {
+            group.send("hi")
+            assertEquals("hi", awaitItem().encodedContent.content.toStringUtf8())
+            group.send("hi again")
+            assertEquals("hi again", awaitItem().encodedContent.content.toStringUtf8())
+        }
+    }
+
+    @Test
+    fun testCanStreamAllMessages() = kotlinx.coroutines.test.runTest {
+        val group = caroClient.conversations.newGroup(listOf(alix.walletAddress))
+        val conversation = boClient.conversations.newConversation(alix.walletAddress)
+        alixClient.conversations.syncGroups()
+        alixClient.conversations.streamAllMessages().test {
+            group.send("hi")
+            assertEquals("hi", awaitItem().encodedContent.content.toStringUtf8())
+            conversation.send("hi again")
+            assertEquals("hi again", awaitItem().encodedContent.content.toStringUtf8())
+        }
+    }
+
     @Test
     fun testCanStreamDecryptedGroupMessages() = kotlinx.coroutines.test.runTest {
         val group = boClient.conversations.newGroup(listOf(alix.walletAddress))
@@ -333,6 +358,31 @@ class GroupTest {
         }
     }
 
+    @Test
+    fun testCanStreamAllDecryptedGroupMessages() = kotlinx.coroutines.test.runTest {
+        val group = caroClient.conversations.newGroup(listOf(alix.walletAddress))
+        alixClient.conversations.syncGroups()
+        alixClient.conversations.streamAllGroupDecryptedMessages().test {
+            group.send("hi")
+            assertEquals("hi", awaitItem().encodedContent.content.toStringUtf8())
+            group.send("hi again")
+            assertEquals("hi again", awaitItem().encodedContent.content.toStringUtf8())
+        }
+    }
+
+    @Test
+    fun testCanStreamAllDecryptedMessages() = kotlinx.coroutines.test.runTest {
+        val group = caroClient.conversations.newGroup(listOf(alix.walletAddress))
+        val conversation = boClient.conversations.newConversation(alix.walletAddress)
+        alixClient.conversations.syncGroups()
+        alixClient.conversations.streamAllDecryptedMessages().test {
+            group.send("hi")
+            assertEquals("hi", awaitItem().encodedContent.content.toStringUtf8())
+            conversation.send("hi again")
+            assertEquals("hi again", awaitItem().encodedContent.content.toStringUtf8())
+        }
+    }
+
     @Test
     fun testCanStreamGroups() = kotlinx.coroutines.test.runTest {
         boClient.conversations.streamGroups().test {