Function effect

packages/infra/test/rpc-e2e-invalidation.test.ts:180–210

(match)

const router = Router(InvRsc)({
  dependencies: [RepoItems.Default, OtherItems.Default],
  *effect(match) {
    const repo = yield* RepoItems
    const otherRepo = yield* OtherItems
    return match({
      DoNothing: () => Effect.void,
      DoWithDynamicKey: Effect.fnUntraced(function*() {
        yield* Invalidation.InvalidationSet.use((_) => _.add(DynamicKey))
        return "done"
      }),
      DoWithBothKeys: Effect.fnUntraced(function*() {
        yield* Invalidation.InvalidationSet.use((_) => _.add(DynamicKey))
        yield* Invalidation.InvalidationSet.use((_) => _.add(ExtraKey))
        return 99
      }),
      DoAndFail: Effect.fnUntraced(function*() {
        yield* Invalidation.InvalidationSet.use((_) => _.add(DynamicKey))
        return yield* Effect.fail(new CmdBoom({ reason: "intentional failure" }))
      }),
      StreamWithKey: () =>
        Stream.fromIterable([1, 2, 3]).pipe(
          Stream.tap(() => Invalidation.InvalidationSet.use((_) => _.add(StreamKey)))
        ),
      StreamWithRepoWrite: () =>
        Stream.fromIterable([1, 2, 3]).pipe(
          Stream.tap((n) => repo.save(new RepoItem({ id: String(n), label: "x" })).pipe(Effect.orDie))
        ),
      GetRepoCount: () => repo.all.pipe(Effect.map((_) => _.length), Effect.orDie),
      SaveRepoItem: ({ id, label }) => repo.save(new RepoItem({ id, label })).pipe(Effect.orDie),
      SaveOtherItem: ({ id, label }) => otherRepo.save(new OtherItem({ id, label })).pipe(Effect.orDie)
    })
  }
})

const RpcRouterLayer = matchAll({ router })