4 ms·
A coworker showed me Akka Streams recently. It allows you to overcome the impedence mismatch between threadpools processing jobs at different speeds where one t
by cmsd2 11y ago
A coworker showed me Akka Streams recently.
It allows you to overcome the impedence mismatch between threadpools processing jobs at different speeds where one task feeds into another.
Could be a neat way to join up the i/o bound tasks to the cpu bound tasks.
https://opencredo.com/introduction-to-akka-streams-getting-started/ https://opencredo.com/introduction-to-akka-streams-getting-s...
- kevinavery 11y agoYep, it's a really cool library. I'm pretty new to it myself, but I made a little gist of how one might approach this problem: https://gist.github.com/kevinavery/941e7d67c4f8b104f610 https://gist.github.com/kevinavery/941e7d67c4f8b104f610 I was kinda surprised by how tricky it was to make a Flow that turned ByteStrings into separate String lines, but it seems like the custom GraphStage approach generalizes really well to more complicated stages.
- wsargent 11y agohttps://rnduja.github.io/2016/03/25/a_first_look_to_akka_stream/ https://rnduja.github.io/2016/03/25/a_first_look_to_akka_str... is also pretty good.