Hello, does anybody know if ktor offer a feature similar to Spring Events Publisher. I mean, I know that you can subscribe to Ktor application events, but would be nice to know if I can throw my CustomEvent and having a custom listener that handle that event.

Folks, does

HttpCache

feature work on iOS? I’ve stumbled upon this and am confused: https://github.com/ktorio/ktor/issues/992.

Any suggestions how to fix below which happened under server CIO load test:

io.ktor.server.cio.HttpServer Fatal exception in coroutines machinery for DispatchedContinuation[ExperimentalCoroutineDispatcher@4bf56b31[scheduler = DefaultDispatcher@1571ced[Pool Size {core = 2, max = 128}, Worker States {CPU = 2, blocking = 1, parked = 0, retired = 0, terminated = 0}, running workers queues = [2c, 0b, 0c], global queue size = 0, Control State Workers {created = 3, blocking = 1}]], Continuation at io.ktor.http.cio.PipelineKt$startConnectionPipeline$1$outputsActor$1.invokeSuspend(Pipeline.kt:77)@7b0cac71]. Please read KDoc to 'handleFatalException' method and report this incident to maintainers

This message was deleted.

Hello! How to retry request in

HttpClientFeature

after

Exception

? Now, I have next code:

override fun install(feature: ExceptionFeature, scope: HttpClient) {
            scope.sendPipeline.intercept(HttpSendPipeline.Before) {
                for (counter in 0..2) {
                    try {
                        proceed()
                        break
                    } catch (e: IOException) {
                        println("IO Error :$counter")
                        if (counter == 2) {
                            throw e
                        }
                    }
                }
            }

Hello all. A noob question. I have two environments,

development

and

deployment

. How do I switch between them?

ktor {
    development {
        port = 8091
        port = ${?DEV_PORT}
    }
    deployment {
        port = 8090
        port = ${?PORT}
    }
    application {
        modules = [ com.rjdesenvolvimento.aries.ApplicationKt.module ]
    }
}

<!here> Folks - important announcement - First off, please welcome our new blog https://blog.jetbrains.com/ktor. Secondly, we’re moving to YouTrack for features/bugs. Please read more on the blog post https://blog.jetbrains.com/ktor/2020/07/migrating-to-youtrack/

How can I use Swagger UI with Ktor, any reference?

Hi folks, anyone have beginner friendly ktor project on github please send the link. I want to learn ktor from projects. Thanks!

I am getting

Response has already been sent

on CIO when serving static files from resources. Is it normal?

Hi all, is it any role management in ktor? Something like in Spring @hasRole or @preauthorized?

Can you point me to some good examples and/or clear documentation on how to deserialize parameters when using Ktor's

ContentNegotiation

feature? I've been banging my head against the wall for ours and it is still not working for me. I have parameter classes with the

@Searializable

annotation:

@Serializable
data class ShowPostURL(
        val date: String,
        val titleSlug: String,
        override val redirectTo: String? = null
)

and no matter what I do

call.receive()

won't work. I'm getting

HTTP 415

errors and Ktor doesn't even log anything. I've added the serialization support as well:

install(ContentNegotiation) {
    json
}

How do I fix this? This is how I'm trying to use it:

accept(ContentType.Any) {
    get(operation.route) {
        val input = call.receive(ShowPostURL::class)
        call.respondText("foo")
    }
}

(cross question from coroutines) Is it a typical pattern to pass around the coroutine scope (io.ktor.application.Application object) as a parameter to my suspend functions?

With the announcement of changing the memory model for kotlin-native in the long run, I am wondering if this has anything to do with freeze exception struggles for the iOS ktor client. Is it still in the plans for the ktor client to overcome freeze exceptions with multithreaded coroutines for the Kotlin 1.4 release?

Is it possible to get a Gson instance in router functions since I’ve installed Gson module? Or I have to new it every time?

the

CIO

server is still experimental. And the message says, that it could be removed. Understanding that this is a generic message to all

KtroExperimental's

should I refrain from the

CIO

server and use

Netty

or others? Any assurance for the

CIO

server?

What do I use in 1.3.2-1.4-M3 instead of

io.ktor:ktor-client-core-native

?

How I get the session id in a get() {}, I just see examples of doing

call.sessions.get<MySession>()

but why isn't there call.sessions.getId or something?

Hi, everyone. I have multiplatform project using ktor. And it’s working fine on Android platform. When I try to compile iOS framework I got following error :

Task :app:compileKotlinIos

w: skipping /Users/nikolaybaklanov/.gradle/caches/modules-2/files-2.1/io.ktor/ktor-client-ios-iosarm64/1.3.1/2f594cbbb3394fe255137a805e4b3f02bfcb5cae/ktor-client-ios.klib. The abi versions don't match. Expected '[22]', found '17'. The library produced by 1.3.61-release-13550 compiler

e: Could not find "/Users/nikolaybaklanov/.gradle/caches/modules-2/files-2.1/io.ktor/ktor-client-ios-iosarm64/1.3.1/2f594cbbb3394fe255137a805e4b3f02bfcb5cae/ktor-client-ios.klib" in [/Users/nikolaybaklanov/Projects/OvercomingPain, /Users/nikolaybaklanov/.konan/klib, /Users/nikolaybaklanov/.konan/kotlin-native-macos-1.3.72/klib/common, /Users/nikolaybaklanov/.konan/kotlin-native-macos-1.3.72/klib/platform/ios_arm64].
15:57:23: Task execution finished 'compileKotlinIos'.

My build.gradle for iOS part :

iosMain {
    dependencies {
        implementation 'org.jetbrains.kotlin:kotlin-stdlib-common:1.3.72'
        implementation 'org.jetbrains.kotlinx:kotlinx-coroutines-core-native:1.3.8'
        implementation "org.jetbrains.kotlinx:kotlinx-serialization-runtime-native:$serialization_version"
        implementation "io.ktor:ktor-client-ios:$ktor_version"
    }
}

kotlin_version=1.3.72
coroutines_version=1.3.0
ktor_version=1.3.1
serialization_version=0.10.0

My log statements somehow do not appear in the Run dialog of Intelij. Can anyone help me know if I'm doing something wrong?

I am (attempting to) use Ktor for client multipart form uploading for an image. I think I every set yp okay, but I am getting extra lines between the header and body like this, which the Apache server we are using may be choking on (still gathering logs). Does this sound believable? If so, any way to fix it?

User-Agent: Ktor client
Content-Length: 153714
Accept-Language: en-us
Accept-Encoding: br, gzip, deflate



--3e9d8564-2440331c-2bc8a4e3-2a59ce744dd5479a2de37096-3fd591e8-4dbb8fc5-
Content-Disposition: form-data; name="p_comId"

Hi, I am very new to the ktor client. What I am trying to do is using it for an integration test using oauth. Using the manual way to add a

Authorization

header manually works, but I need to automate it using clientCredentials flow and client-id and client-secret. So far when I google about it, I just get how to set up oauth with ktor on the server-side, not on the client side. Has anybody done so and can give me a code example or a link where I can find help?

how do i read a string from a

ByteReadChannel

? i know there is

.readUTF8Line()

but what if my string contains newlines ? do i have to convert the string to a bytearray and send that (preceded with its size) or is there a better way ?

i need to write a simple endpoint which receives a file via http and passes it on to the aws sdk transfermanager for uploading to S3. can i do it in a way that i only handle streams, so that the file is never fully read (to memory/disk). files are very, VERY big. how could i do that with ktor?

Hello. We encountered a scenario with routes and interceptors that seems weird. Please consider the scenario below:

fun Route.routeA() = route("/a") {
  intercept(ApplicationCallPipeline.Call) {
    <do_something_a>
  }
}

fun Route.routeB() = route("/a/{some_value}") {
  intercept(ApplicationCallPipeline.Call) {
    <do_something_b>
  }
}

routing {
  routeB()
  routeA()
}

When we send a request to

/a/some_value

, the request goes through

do_something_a

first before

do_something_b

. Is this the expected behavior? Our expectation is that only

do_something_b

would be triggered, since in this case

routeB

is not a child route of

routeA

Note: We separated the routes due to the hope that the interceptor will only be applied to the enclosing route. We have some business requirement where ACL is different on those scenarios

Hello, Is there a way to disable content-negotiation before receiving a single call? The problem I'm trying to solve is that I want to write the content of the request to log if Gson throws a JsonParseException, but calling call.receiveText() from the exception handler will just result in a

RequestReceiveAlreadyFailedException: Request body consumption was failed

.

Would you consider WebSocket Feature production ready and ready to handle a lot or concurrent users ex: For a mobile game ? Is it stable ?

What is the current status of availability of version of

ktor

that works with

native-mt

version of koltinx coroutines?