From 72c9ae9864fce6af0dafb5467953345ce78c2b91 Mon Sep 17 00:00:00 2001 From: Naomi Plasterer Date: Thu, 20 Feb 2025 07:33:12 -0800 Subject: [PATCH] fix the format --- .../java/org/xmtp/android/library/ConversationsTest.kt | 10 +++++----- 1 file changed, 5 insertions(+), 5 deletions(-) diff --git a/library/src/androidTest/java/org/xmtp/android/library/ConversationsTest.kt b/library/src/androidTest/java/org/xmtp/android/library/ConversationsTest.kt index 4d547a9f..79af3d7c 100644 --- a/library/src/androidTest/java/org/xmtp/android/library/ConversationsTest.kt +++ b/library/src/androidTest/java/org/xmtp/android/library/ConversationsTest.kt @@ -271,8 +271,10 @@ class ConversationsTest { @Test fun testStreamsAndMessages() = runBlocking { val messages = mutableListOf() - val alixGroup = alixClient.conversations.newGroup(listOf(caroClient.address, boClient.address)) - val caroGroup2 = caroClient.conversations.newGroup(listOf(alixClient.address, boClient.address)) + val alixGroup = + alixClient.conversations.newGroup(listOf(caroClient.address, boClient.address)) + val caroGroup2 = + caroClient.conversations.newGroup(listOf(alixClient.address, boClient.address)) // Ensure all clients sync before sending/receiving @@ -290,7 +292,7 @@ class ConversationsTest { try { withTimeout(60.seconds) { // Ensure test doesn't hang indefinitely caroClient.conversations.streamAllMessages() - .take(80) // Stop after receiving 80 messages + .take(100) // Stop after receiving 90 messages .collect { message -> synchronized(messages) { messages.add(message.body) } println("Caro received: ${message.body}") @@ -351,7 +353,6 @@ class ConversationsTest { caroJob.cancelAndJoin() - Log.d("LOPI", messages.toString()) assertEquals(90, messages.size) assertEquals(40, caroGroup.messages().size) @@ -363,5 +364,4 @@ class ConversationsTest { assertEquals(41, alixGroup.messages().size) assertEquals(40, caroGroup.messages().size) } - }