Implementing a Concurrent Pipeline with Effect and Concurrency

I'm really struggling to get a simple pipeline in place... Given the following:

const getRows: Effect<Row[], Error, DB>
const processRow: (row: Row) => Effect<Result, Error, API>


I'd like to simply get the rows, then process all of the rows with a concurrency of N.
Was this page helpful?