@@ -3,7 +3,6 @@ package org.xmtp.android.library
3
3
import androidx.test.ext.junit.runners.AndroidJUnit4
4
4
import androidx.test.platform.app.InstrumentationRegistry
5
5
import app.cash.turbine.test
6
- import kotlinx.coroutines.ExperimentalCoroutinesApi
7
6
import kotlinx.coroutines.runBlocking
8
7
import org.junit.Assert.assertEquals
9
8
import org.junit.Assert.assertThrows
@@ -217,11 +216,9 @@ class GroupTest {
217
216
assertEquals(ReactionSchema .Unicode , content?.schema)
218
217
}
219
218
220
- @OptIn(ExperimentalCoroutinesApi ::class )
221
219
@Test
222
220
fun testCanStreamGroupMessages () = kotlinx.coroutines.test.runTest {
223
221
val group = boClient.conversations.newGroup(listOf (alix.walletAddress.lowercase()))
224
-
225
222
group.streamMessages().test {
226
223
group.send(" hi" )
227
224
assertEquals(" hi" , awaitItem().body)
@@ -230,7 +227,6 @@ class GroupTest {
230
227
}
231
228
}
232
229
233
- @OptIn(ExperimentalCoroutinesApi ::class )
234
230
@Test
235
231
fun testCanStreamDecryptedGroupMessages () = kotlinx.coroutines.test.runTest {
236
232
val group = boClient.conversations.newGroup(listOf (alix.walletAddress))
@@ -243,7 +239,6 @@ class GroupTest {
243
239
}
244
240
}
245
241
246
- @OptIn(ExperimentalCoroutinesApi ::class )
247
242
@Test
248
243
fun testCanStreamGroups () = kotlinx.coroutines.test.runTest {
249
244
boClient.conversations.streamGroups().test {
@@ -256,7 +251,6 @@ class GroupTest {
256
251
}
257
252
}
258
253
259
- @OptIn(ExperimentalCoroutinesApi ::class )
260
254
@Test
261
255
fun testCanStreamGroupsAndConversations () = kotlinx.coroutines.test.runTest {
262
256
boClient.conversations.streamAll().test {
0 commit comments