(
gen: Effect.Effect<readonly [Iterable<P>, Iterable<Evt>, A], E, R>
)
| 83 | } |
| 84 | |
| 85 | function saveAllWithEffectInt< |
| 86 | P extends T, |
| 87 | R, |
| 88 | E, |
| 89 | A |
| 90 | >( |
| 91 | gen: Effect.Effect<readonly [Iterable<P>, Iterable<Evt>, A], E, R> |
| 92 | ): Effect.Effect< |
| 93 | A, |
| 94 | E | InvalidStateError | OptimisticConcurrencyException | DatabaseError, |
| 95 | R | RSchema | RPublish |
| 96 | > { |
| 97 | return Effect.flatMap(gen, ([items, events, a]) => repo.saveAndPublish(items, events).pipe(Effect.map(() => a))) |
no test coverage detected
searching dependent graphs…