From 7b7f6722b78e45f24758980194c860308d723c58 Mon Sep 17 00:00:00 2001 From: cameronvoell Date: Wed, 28 Feb 2024 09:18:40 -0700 Subject: [PATCH] Adds test for streamGroupMessages --- .../java/org/xmtp/android/library/GroupTest.kt | 14 ++++++++++++++ 1 file changed, 14 insertions(+) diff --git a/library/src/androidTest/java/org/xmtp/android/library/GroupTest.kt b/library/src/androidTest/java/org/xmtp/android/library/GroupTest.kt index 1758f694b..2ac300a0d 100644 --- a/library/src/androidTest/java/org/xmtp/android/library/GroupTest.kt +++ b/library/src/androidTest/java/org/xmtp/android/library/GroupTest.kt @@ -379,6 +379,20 @@ class GroupTest { } } + @Test + fun testCanStreamDecryptedGroupMessagesFromSelf() = kotlinx.coroutines.test.runTest { + val group = boClient.conversations.newGroup(listOf(alix.walletAddress)) + alixClient.conversations.syncGroups() + val alixGroup = alixClient.conversations.listGroups().first() + group.streamDecryptedMessages().test { + + alixGroup.send("hi") + assertEquals("hi", awaitItem().encodedContent.content.toStringUtf8()) + group.send("hi from self") + assertEquals("hi from self", awaitItem().encodedContent.content.toStringUtf8()) + } + } + @Test fun testCanStreamAllDecryptedGroupMessages() = kotlinx.coroutines.test.runTest { val group = caroClient.conversations.newGroup(listOf(alix.walletAddress))