criticalbh
"The best" way to listen to grpc stream and process it
Hello,
I have grpc stream that is streaming price_value updates for specific symbol (e.g. EUR).
I have implemented one solution using poolboy where I spawn worker for each symbol and listen to stream inside the worker.
Now, the more I read and research I feel this is not the good way.
Is the genstage answer for this? I was thinking that for each symbol I can spin up producer that will listen to stream and then emit events to consumers which will eventually feed the data into mqtt.
First Post!
Fl4m3Ph03n1x
Welcome to the forum Admir ! We hope you find this place helpful and friendly.
If you are considering GenStage, perhaps you should take a look at Flow, which was created to deal with streams in a concurrent / parallel fashion and is built on top of GenStage:
Popular in Questions
Other popular topics
Latest on Elixir Forum
Sponsor Spotlight
We build reliable cloud platforms for business-critical systems.
Categories:
Sub Categories:
Forums
Our Sponsors
Build Elixir applications with speed and confidence.
Supporting innovation across the BEAM ecosystem.
We build reliable cloud platforms for business-critical systems.
Catch errors, track performance, monitor hosts and more.
Practical resources that improve the lives of professional developers.
Develop your skills with books, videos, and courses.
The deployment platform built for Elixir: PaaS ease, VPS control.
Courses that'll move you from confusion to "Aha, now I get it!"