Hi everyone Anyone face this error before Exception in thread "eventLoopGroupProxy-3-1 @response-pipeline#3" kotlinx.coroutines.CoroutinesInternalError: Fatal exception in coroutines machinery for DispatchedContinuation[UnsafeBlockingTrampoline@76907f9f, Continuation at io.ktor.utils.io.jvm.javaio.OutputAdapter$loop$1.loop(Blocking.kt:311)@aa7a293]. Please read KDoc to 'handleFatalException' method and report this incident to maintainers

i have a global

val client = HttpClient(OkHttp)

and apparently it opens a coroutine / thread that is not closed when the program is done.. so it hangs i am not entirely sure what change on my side triggered this or if i am using it incorrectly if i do

exitProcess(0)

i can kill it but i'd prefer to avoid that more in :thread-please:

Hi everybody! 👋 My name is Elvira, I’m doing research on how developers are using Ktor for server-side development, and particularly its plugin for IDEA, to figure out its potential improvements. For that I’d like to speak to you about your experience with it. Would anyone be up for a short interview sometime this weekend or early next week? It won’t take longer than 30 min. If so, please, drop me a private message or leave a comment here in the thread. Thank you very much, I’d really appreciate it!

I actually didn’t solved. Suddenly it began doing this thing of chopping my request again. I got to where it is happening but still don’t get why So, in the Ktor.JVM, when this data goes in: “Reminder(actionType=boolean, from=slorg@gmail.com, hours=[200], startDate=2020-10-29T01:31:16.993Z, title=Hkkljf, to=jorebs@gmail.com, frequency=1, frequencyType=no_repeatable)” And when it goes trough package

io.ktor.client.features.json.serializer
internal fun writeContent(data: Any): String =
    json.encodeToString(buildSerializer(data, json.serializersModule), data)

This is in like 29 this comes out: {“from”:“slorg@gmail.com”,“hours”:[200],“startDate”:“2020-10-29T01:31:16.993Z”,“title”:“Hkkljf”,“to”:“jorebs@gmail.com”}

How can I imagine the Ktor websockets? Are they so that the browser permanently shows "refresh" or are they like a JavaScript file so that the user doesn't really notice them?

So Ktor Http client with default engines for Android and iOS doesn’t support mt coroutines and Ktor http client with CIO engine supports mt coroutines but doesn’t support https? Is it this way or am I doing something wrong?

Hey how can a store a websocket session to send a message to the websocket later?

I have joined the channel to have a chat about graphql support for ktor, would this be the right place to open a thread about it?

I found few messages about graphql in ktor in this channel so here it goes… I have created an example using ktor for graphql-kotlin library here https://github.com/ExpediaGroup/graphql-kotlin/pull/951 it was merged in but there is still some work to do to support subscriptions. It’s where I started thinking, there are a few initiatives to implement graphql in kotlin which take slightly different approaches. I would like to personally get involved into one of them. Before I make my decision I would like to know, though, if ktor team has any favourite approach or if it is planning to provide their own implementation?

Is Ktor 1.4.1 compatible with Kotlin 1.4.20?

Just an FYI: I just tried to update to Ktor 1.4.3 (got the announcement email), and it breaks some of our APIs due to the fact that it no longer encodes all ‘=’ in the query parameters. See here: https://github.com/ktorio/ktor/commit/a55249b7495c4f4426f458d6cb56b7122e025cb3 I agree that according to the spec this ought to work fine, and it is more of an issue on our (admittedly old) server code. But perhaps it might adversely impact others as well. Thanks.

1.4.3 Release We’ve released 1.4.3. As always, please check the change log at https://ktor.io/changelog/

Should Ktor 1.4.3 work with Kotlin/Native and, if so, are there particular associated dependencies it needs? I see for example it still has transitive dependency to

v1.3.9-native-mt-2

of kotlinx coroutines whereas I'm using

1.4.2-native-mt

(which is working btw with Ktor 1.4.0)

Hi 👋 I’m playing with ktor on Android platform, to see how it works. I managed to test the

get

request, but i’m hitting

MissingFieldException

when trying out

post

. Can smbd please check what I might be doing wrong? Thanks in advance! Some code snippets:

@Serializable
data class RegistrationParams(
    val name: String,
    val job: String
)

@Serializable
data class RegistrationResponse(
    @SerialName("name") val name: String,
    @SerialName("job") val job: String,
    @SerialName("id") val id: String,
    @SerialName("createdAt") val createdAt: String
)

val httpClient = HttpClient(Android) {
        install(JsonFeature) {
            val json = Json { ignoreUnknownKeys = true }
            serializer = KotlinxSerializer(json = json)
        }
    }

suspend fun samplePostRequest(): RegistrationResponse = <http://client.post|client.post>(
        urlString = "<https://reqres.in/api/users>",
    ) {
        body = Json.encodeToString(
            RegistrationParams.serializer(),
            RegistrationParams(
                name = "Neo",
                job = "The Chosen One"
            )
        )
    }

The error message says:

Field 'name' is required, but it was missing

What’s the reason Ktor is no longer published through Bintray? Was it too slow/unreliable?

Hi folks. I wanted to use

kotlinx.serialization

in

ContentNegotiation

and I can’t find the artifact containing that

serialization()

method as stated in the ktor docs

install(ContentNegotiation) {
    serialization()
}

Do you know which artifact I need to include in the gradle file?

Am I correct that ktor sockets can not be used on ios? https://ktor.io/docs/servers-raw-sockets.html#client These examples show a

ActorSelectorManager

which I can only find on the jvm

Hi, I'm trying out ktor and reading the HTTP API—Ktor 1.4.0, but when I make post request it gives me Caused by: io.ktor.features.CannotTransformContentToTypeException: Cannot transform this request's content to com.example.LoginRegister

I'm always running my Kotlin web stuff behind nginx, but the nginx seems to do nothing for me. It's just more annoying configuration. Do you think I could run Ktor on ports 80 and 443 and have it be the main web server?

Hi everyone I'm using jwt auth I don't understand how I set the values of domain, audience and realm in the application.conf Should anyone explain to me how get that values and set it in my project

I’m having trouble using ktor http client 1.4.3 in the common layer. I can’t resolve the code in the IDE. Downgrading to 1.4.2 fixes it.

Hi all, we built an API that allows the upload of JSON data. We would like to limit the request body size to a fixed number of MB. we didn't find any such feature in ktor, nor in the underlying Jetty engine (not for json content type). So we implemented our own function that would parse the input stream and stop once it is too many bytes As this is using blocking API, we are not sure whether this will cause problems down the road? We wonder how ktor itself receives json in a non-blocking way?

suspend fun PipelineContext<Unit, ApplicationCall>.receiveCarefully(): String? =
        @Suppress("BlockingMethodInNonBlockingContext")
        withContext(<http://Dispatchers.IO|Dispatchers.IO>) {
            val bodyBuilder = StringBuilder()
            val stream = call.receiveStream()
            stream.reader().use { reader ->
                do {
                    val chars = CharArray(8192)
                    val numRead = reader.read(chars)
                    if (numRead > 0) {
                        bodyBuilder.append(String(chars, 0, numRead))
                        if (bodyBuilder.length > AppConfig.maxUploadChars) {
                            return@withContext null
                        }
                    }
                } while (numRead > -1)
                bodyBuilder.toString()
            }
        }

I have this webscocket code:

fun openWebSocket(scope: CoroutineScope = GlobalScope, consumer: JsonRpcListener) {
        scope.launch {
            <http://httpClient.ws|httpClient.ws>(method = HttpMethod.Get, host = host, port = port, path = path) {
                incoming.consumeAsFlow()
                    .onEach { consumer.run(it) }
                    .collect()
            }
        }
    }

So how do I close the ws from client side?

Hi folks. I'm using Ktor to connect to a WebSocket server using the OkHTTP engine. Does Ktor proactively detect and terminate broken connections using WebSocket pings? If not, how can I do it manually? I can't find any docs on this.

fun main() = runBlocking {
    val httpClient = HttpClient {
        install(Logging) {
            level = LogLevel.ALL
        }
        @OptIn(KtorExperimentalAPI::class)
        install(WebSockets)
        expectSuccess = false
        install(JsonFeature) {
            @OptIn(KtorExperimentalAPI::class)
            acceptContentTypes = listOf(ContentType("application", "json-rpc"))
            serializer = KotlinxSerializer()
        }
    }
    val wss =httpClient.webSocketSession(method = HttpMethod.Get, host = "127.0.0.1", port = 6800, path = "/jsonrpc")
    wss.close()
}

this does not stop the program. what am I doing wrong?

What do you guys use for mongodb in your ktor apps?

in the ContentNegotiation source there is a comment saying

// Respond with "415 Unsupported Media Type" if content cannot be transformed on receive

but when i send a json body to my server where one field name is misspelled, I get a 500 internal server error reply instead.

is the

jvmTest

gradle task supposed to finish without errors? I’m getting a lot of timeouts (on macOs)

<!here> Folks, as some of you may have heard, GitHub announced support for Discussion forums. On the Ktor team we use SO as the main forum, and then there are peer to peer mediums such as this channel. How would folks feel about opening up discussions on GitHub?