3 replies

When using withParallelism, how to collect all result?

I have the following code:

F.pipe(
  i.resources,
  Effect.forEachPar(updatePicture),
  Effect.withParallelism(20)
)

F.pipe(
  i.resources,
  Effect.forEachPar(updatePicture),
  Effect.withParallelism(20)
)

I would like to

collect

collect

all the result of the

updatePicture

updatePicture

function.

I saw

Effect.collectAllPar

Effect.collectAllPar

, but I'm not sure how to use it.

I naively tried that:

 F.pipe(
  i.resources,
  Effect.map((resource) => updatePicture(resource)),
  Effect.collectAllPar
  Effect.withParallelism(20)
)

 F.pipe(
  i.resources,
  Effect.map((resource) => updatePicture(resource)),
  Effect.collectAllPar
  Effect.withParallelism(20)
)

But this is not working

Any help on how to use

Effect.collectAllPar

Effect.collectAllPar

3 replies

I have the following code:

F.pipe(
  i.resources,
  Effect.forEachPar(updatePicture),
  Effect.withParallelism(20)
)

F.pipe(
  i.resources,
  Effect.forEachPar(updatePicture),
  Effect.withParallelism(20)
)

I would like to

collect

collect

all the result of the

updatePicture

updatePicture

function.

I saw

Effect.collectAllPar

Effect.collectAllPar

, but I'm not sure how to use it.

I naively tried that:

 F.pipe(
  i.resources,
  Effect.map((resource) => updatePicture(resource)),
  Effect.collectAllPar
  Effect.withParallelism(20)
)

 F.pipe(
  i.resources,
  Effect.map((resource) => updatePicture(resource)),
  Effect.collectAllPar
  Effect.withParallelism(20)
)

But this is not working

Any help on how to use

Effect.collectAllPar

Effect.collectAllPar