how to read deserialized incoming messages continuously ? or as a flow in

ktor 2.x

? Should we read in a

while(true){}

client.wss() {
   while (true) {
      val customer = receiveDeserialized<Customer>()
   }
}

Thanks for the question.

receiveDeserialized

should be used with

while

. For example:

client.wss() {
   try {
      while(true) {
        val customer = receiveDeserialized<Customer>()
      }
   } catch (t: Throwable) {
      ...
   }
}

If you wish to deserialize incoming messages in a flow, you could write something like this:

val converter: WebsocketContentConverter = ...
val customers = incoming.consumeAsFlow()
    .map {
         converter.deserialize(
             charset = call.request.headers.suitableCharset(),
             typeInfo = typeInfo<Customer>(),
             content = it
         )
   }.collect()

Thank you for your help, 👍