Seeking Help with Concurrent Fetch Operations and Streaming Results in Effect-TS
Hello everyone,
My first interaction on discord in effect community here
I’m trying to do something with Effect-TS but couldn’t figure out how.
Here is the problem:
Given a list of n elements, I want to perform a fetch operation on each element. I want to add concurrency so that no more than x fetch requests are made simultaneously. I do not want to wait until all results are returned; instead, I want to stream the results back as they come through.
So I can
Effect.all(effects) with concurrency x makes sense.
But how can I stream the results as they come?
Thanks for the help in advance
My first interaction on discord in effect community here
I’m trying to do something with Effect-TS but couldn’t figure out how.
Here is the problem:
Given a list of n elements, I want to perform a fetch operation on each element. I want to add concurrency so that no more than x fetch requests are made simultaneously. I do not want to wait until all results are returned; instead, I want to stream the results back as they come through.
So I can
Effect.all(effects) with concurrency x makes sense.
But how can I stream the results as they come?
Thanks for the help in advance
