Skip to content

Commit 26c0252

Browse files
committed
Reformat
1 parent ac5377f commit 26c0252

File tree

1 file changed

+10
-9
lines changed

1 file changed

+10
-9
lines changed

core/src/commonIntegrationTest/kotlin/com/powersync/sync/SyncIntegrationTest.kt

Lines changed: 10 additions & 9 deletions
Original file line numberDiff line numberDiff line change
@@ -915,16 +915,17 @@ class NewSyncIntegrationTest : BaseSyncIntegrationTest(true) {
915915
}
916916

917917
@Test
918-
fun `ends iteration on http close`() = databaseTest {
919-
turbineScope(timeout = 10.0.seconds) {
920-
val turbine = database.currentStatus.asFlow().testIn(this)
921-
database.connect(TestConnector(), options = getOptions())
922-
turbine.waitFor { it.connected }
918+
fun `ends iteration on http close`() =
919+
databaseTest {
920+
turbineScope(timeout = 10.0.seconds) {
921+
val turbine = database.currentStatus.asFlow().testIn(this)
922+
database.connect(TestConnector(), options = getOptions())
923+
turbine.waitFor { it.connected }
923924

924-
syncLines.close()
925-
turbine.waitFor { !it.connected }
925+
syncLines.close()
926+
turbine.waitFor { !it.connected }
926927

927-
turbine.cancelAndIgnoreRemainingEvents()
928+
turbine.cancelAndIgnoreRemainingEvents()
929+
}
928930
}
929-
}
930931
}

0 commit comments

Comments
 (0)