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 1758f694..2ac300a0 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))