how to read deserialized incoming messages continuously ? or as a flow in `ktor 2.x` ? Should we...

# ktor

[brabo-hi]

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>()
   }
}

[brabo-hi]

i know we could read incoming messages but as frame using incoming.consumeAsFlow()

[Aleksei Tirman [JB]]

@Daria Usova

[Daria Usova]

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()

[brabo-hi]

Thank you for your help, 👍