Bug: Failing to stream when streaming client creates group/dm

[cameronvoell]

Describe the bug

• note this bug for now seems android only - equivalent functionality seem to be working in xmtp-ios

testCanStreamGroupsAndConversations in ConversationsTest.kt started failing on xmtp-android main starting with commit 65be7d1. which merged PR #363 .

That PR updated libxmtp ref from fc37819c to a48e9a79

xmtp-android/library/src/androidTest/java/org/xmtp/android/library/ConversationsTest.kt

Lines 212 to 235 in 28aebb5

	fun testCanStreamGroupsAndConversations() {
	val allMessages = mutableListOf<String>()
	val job = CoroutineScope(Dispatchers.IO).launch {
	try {
	boClient.conversations.stream()
	.collect { message ->
	allMessages.add(message.topic)
	}
	} catch (e: Exception) {
	}
	}
	Thread.sleep(1000)
	runBlocking {
	caroClient.conversations.newGroup(listOf(bo.walletAddress))
	Thread.sleep(1000)
	boClient.conversations.findOrCreateDm(caro.walletAddress)
	}
	Thread.sleep(2000)
	assertEquals(2, allMessages.size)
	job.cancel()
	}

Expected behavior

No response

Steps to reproduce the bug

No response

[cameronvoell]

other format for streaming test also failing when streaming client creates group:

see modified test on branch here:

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

Lines 746 to 756 in 131f415

	@Test
	fun testCanStreamGroups() = kotlinx.coroutines.test.runTest {
	boClient.conversations.stream(type = ConversationType.GROUPS).test {
	val group =
	alixClient.conversations.newGroup(listOf(bo.walletAddress))
	assertEquals(group.id, awaitItem().id)
	val group2 =
	boClient.conversations.newGroup(listOf(caro.walletAddress))
	assertEquals(group2.id, awaitItem().id)
	}
	}

[nplasterer]

Seeing this fail in RN as well consistently across iOS and Android. Dms created by self are failing.

[cameronvoell]

Was able to test this fix on xmtp-android, and xmtp-react-native android, looks like it clears up the issue 🎉
xmtp/libxmtp#1613

Will close out this issue once we have that fix merged through the SDKS