I was used to code Scala in the last 4y and we used akka.streams a lot, switching from sync to async was so easy and we didn’t have this CompletionStage vs ListenableFuture vs Spring ListenableFuture problems.
Now i am using Kotlin in my new company and we have mappers to convert everything to coroutines, but i really miss my streams, i never really got comfy with coroutines. I am still used to think in streams or flows, in Entitys that are mapped, processed, that are running through a graph.
Is there something in Kotlin to replace that? That follows the same principles, reactive, nonblocking, backpressured?