Skip to content

Commit ce83e36

Browse files
authored
Use Dispatchers.IO for IOBridge (#4478)
1 parent 24c293e commit ce83e36

File tree

3 files changed

+6
-4
lines changed

3 files changed

+6
-4
lines changed

ktor-server/ktor-server-cio/posix/src/io/ktor/server/cio/internal/CoroutineUtilsNix.kt

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -7,4 +7,4 @@ package io.ktor.server.cio.internal
77
import kotlinx.coroutines.*
88

99
internal actual val Dispatchers.IOBridge: CoroutineDispatcher
10-
get() = Default
10+
get() = IO

ktor-server/ktor-server-core/posix/src/io/ktor/server/engine/internal/ApplicationUtilsNix.kt

Lines changed: 4 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -9,10 +9,12 @@ import io.ktor.server.engine.*
99
import kotlinx.cinterop.*
1010
import kotlinx.coroutines.*
1111
import platform.posix.*
12+
import kotlin.experimental.*
1213

13-
internal actual fun availableProcessorsBridge(): Int = 1
14+
@OptIn(ExperimentalNativeApi::class)
15+
internal actual fun availableProcessorsBridge(): Int = Platform.getAvailableProcessors()
1416

15-
internal actual val Dispatchers.IOBridge: CoroutineDispatcher get() = Default
17+
internal actual val Dispatchers.IOBridge: CoroutineDispatcher get() = IO
1618

1719
@OptIn(ExperimentalForeignApi::class)
1820
internal actual fun printError(message: Any?) {

ktor-server/ktor-server-test-host/posix/src/io/ktor/server/testing/internal/CoroutineUtilsNix.kt

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -6,6 +6,6 @@ package io.ktor.server.testing.internal
66

77
import kotlinx.coroutines.*
88

9-
internal actual val Dispatchers.IOBridge: CoroutineDispatcher get() = Default
9+
internal actual val Dispatchers.IOBridge: CoroutineDispatcher get() = IO
1010

1111
internal actual fun <T> maybeRunBlocking(block: suspend CoroutineScope.() -> T): T = runBlocking(block = block)

0 commit comments

Comments
 (0)