im sorry to ask this simple question, but I would ...
# coroutinesd
Daniel
05/15/2022, 6:00 PMim sorry to ask this simple question, but I would love some hints on what to read/google on because I'm a little lost. I have a controller that has an Micronaut EventListener listening for events, when a new event has been received its emitted on a Reactor Sink which is exposed as a http endpoint where clients can receive a APPLICATION_JSON_STREAM of new events. Now my next attempt is to rewrite this to Kotlin Coroutines but I dont know much about coroutines yet and I dont find what the comparable concept of a Reactor Sink in coroutines. Could anyone point me in the right direction on what I should study up on? This is my attempt on Reactor Sinks https://github.com/nsbno/trafficinfo-baseline-micronaut/blob/streaming-fullstate/src/main/kotlin/no/vy/trafficinfo/baseline/micronaut/controllers/ChangeController.kt