Update SourceOfTruthWithBarrierTests to use Turbine

Signed-off-by: matt-ramotar <[email protected]>

Author: matt-ramotar

store/src/commonTest/kotlin/org/mobilenativefoundation/store/store5/SourceOfTruthWithBarrierTests.kt

@@ -15,6 +15,7 @@
  */
 package org.mobilenativefoundation.store.store5
 
+import app.cash.turbine.test
 import kotlinx.coroutines.CompletableDeferred
 import kotlinx.coroutines.ExperimentalCoroutinesApi
 import kotlinx.coroutines.FlowPreview
@@ -32,7 +33,6 @@ import org.mobilenativefoundation.store.store5.SourceOfTruth.WriteException
 import org.mobilenativefoundation.store.store5.impl.PersistentSourceOfTruth
 import org.mobilenativefoundation.store.store5.impl.SourceOfTruthWithBarrier
 import org.mobilenativefoundation.store.store5.util.InMemoryPersister
-import org.mobilenativefoundation.store.store5.util.assertEmitsExactly
 import kotlin.test.Test
 import kotlin.test.assertEquals
 import kotlin.test.assertNull
@@ -147,19 +147,20 @@ class SourceOfTruthWithBarrierTests {
             persister.postReadCallback = { key, value ->
                 throw exception
             }
-            assertEmitsExactly(
-                source.reader(1, CompletableDeferred(Unit)),
-                listOf(
+
+            source.reader(1, CompletableDeferred(Unit)).test {
+                assertEquals(
                     StoreReadResponse.Error.Exception(
                         origin = StoreReadResponseOrigin.SourceOfTruth,
                         error =
-                            ReadException(
-                                key = 1,
-                                cause = exception,
-                            ),
+                        ReadException(
+                            key = 1,
+                            cause = exception,
+                        ),
                     ),
-                ),
-            )
+                    awaitItem()
+                )
+            }
         }
 
     @Test
@@ -187,10 +188,10 @@ class SourceOfTruthWithBarrierTests {
                 StoreReadResponse.Error.Exception(
                     origin = StoreReadResponseOrigin.SourceOfTruth,
                     error =
-                        ReadException(
-                            key = 1,
-                            cause = exception,
-                        ),
+                    ReadException(
+                        key = 1,
+                        cause = exception,
+                    ),
                 ),
                 collected.first(),
             )
@@ -204,10 +205,10 @@ class SourceOfTruthWithBarrierTests {
                     StoreReadResponse.Error.Exception(
                         origin = StoreReadResponseOrigin.SourceOfTruth,
                         error =
-                            ReadException(
-                                key = 1,
-                                cause = exception,
-                            ),
+                        ReadException(
+                            key = 1,
+                            cause = exception,
+                        ),
                     ),
                     StoreReadResponse.Data(
                         // this is fetcher since we are using the write API
@@ -253,11 +254,11 @@ class SourceOfTruthWithBarrierTests {
                     StoreReadResponse.Error.Exception(
                         origin = StoreReadResponseOrigin.SourceOfTruth,
                         error =
-                            WriteException(
-                                key = 1,
-                                value = failValue,
-                                cause = exception,
-                            ),
+                        WriteException(
+                            key = 1,
+                            value = failValue,
+                            cause = exception,
+                        ),
                     ),
                     StoreReadResponse.Data<String?>(
                         origin = StoreReadResponseOrigin.SourceOfTruth,