Hi, could someone recommend me something equivalent to akka-streams native to Kotlin, I need something lightweight that can handle backpressure and publish/subscribe patterns? thanks
Ролан
05/07/2021, 5:29 PM
kotlinx-coroutines should be comparable? if someone ever used both
☝️ 2
j
Johannes Koenen
05/07/2021, 5:39 PM
Yeah
Flow
from kotlinx-coroutines is comparabale. Or rxjava/reactor.
If you're very sold on the Alpakka integrations you could also try using akka's Java api.
Interop between all those libraries is fairly good thanks to them all being reactive-streams compliant
Johannes Koenen
05/07/2021, 5:41 PM
I'd suggest to start off with flow and coroutines, as you said.
Hey everyone. Just wanted report that in the end using coroutines based reactive streams in Kotlin was good enough for us to get running a platform fetching and processing limit order books from crypto-exchanges. Code available on this repo: https://github.com/grinisrit/noa-atra-examples