fix Effect.forEach usage (#164)

Effect-TS · Aug 30, 2023 · d031d7f · d031d7f
1 parent c83aaf8
commit d031d7f
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/src/internal/sink.ts b/src/internal/sink.ts
@@ -377,7 +377,7 @@ export const contramapEffect = dual<
       self,
       (chunk) =>
         Effect.map(
-          Effect.forEach(chunk, f),
+          Effect.forEach(chunk, (v) => f(v)),
           Chunk.unsafeFromArray
         )
     )
@@ -1375,7 +1375,7 @@ export const flatMap = dual<
 export const forEach = <In, R, E, _>(f: (input: In) => Effect.Effect<R, E, _>): Sink.Sink<R, E, In, never, void> => {
   const process: Channel.Channel<R, E, Chunk.Chunk<In>, unknown, E, never, void> = core.readWithCause({
     onInput: (input: Chunk.Chunk<In>) =>
-      pipe(core.fromEffect(Effect.forEach(input, f, { discard: true })), core.flatMap(() => process)),
+      pipe(core.fromEffect(Effect.forEach(input, (v) => f(v), { discard: true })), core.flatMap(() => process)),
     onFailure: core.failCause,
     onDone: () => core.unit
   })