Skip to content

Commit f1f4f11

Browse files
committed
harden awaitIO with timeout
1 parent 7511d23 commit f1f4f11

File tree

1 file changed

+5
-2
lines changed
  • OneSignalSDK/onesignal/testhelpers/src/main/java/com/onesignal/mocks

1 file changed

+5
-2
lines changed

OneSignalSDK/onesignal/testhelpers/src/main/java/com/onesignal/mocks/IOMockHelper.kt

Lines changed: 5 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -12,6 +12,7 @@ import io.mockk.every
1212
import io.mockk.mockkStatic
1313
import io.mockk.unmockkStatic
1414
import kotlinx.coroutines.CompletableDeferred
15+
import kotlinx.coroutines.withTimeout
1516
import java.util.concurrent.atomic.AtomicInteger
1617

1718
/**
@@ -73,11 +74,13 @@ object IOMockHelper : BeforeSpecListener, AfterSpecListener, BeforeTestListener,
7374
* interception surface minimal and avoids unintentionally changing more concurrency
7475
* behavior than necessary.
7576
*/
76-
suspend fun awaitIO() {
77+
suspend fun awaitIO(timeoutMs: Long = 5_000) {
7778
// Nothing to wait for in this case
7879
if (pendingIo.get() == 0) return
7980

80-
ioWaiter.await()
81+
withTimeout(timeoutMs) {
82+
ioWaiter.await()
83+
}
8184
}
8285

8386
override suspend fun beforeSpec(spec: Spec) {

0 commit comments

Comments
 (0)