diff --git a/packages/server/src/trpc.ts b/packages/server/src/TRPCEffectRuntime.ts similarity index 86% rename from packages/server/src/trpc.ts rename to packages/server/src/TRPCEffectRuntime.ts index 4db6c22..ae3c09e 100644 --- a/packages/server/src/trpc.ts +++ b/packages/server/src/TRPCEffectRuntime.ts @@ -5,14 +5,14 @@ import { MainLive, type MainR } from "./Main" import { TodoRepository } from "./TodoRepository" -export class TRPCEffectRunner extends Context.Tag("TRPCEffectRunner")( self: Effect.Effect, options?: Runtime.RunForkOptions, ) => RuntimeFiber >() {} -export const TRPCEffectRunnerLive = Layer.effect(TRPCEffectRunner, +export const TRPCEffectRuntimeLive = Layer.effect(TRPCEffectRuntime, Effect.runtime().pipe( Effect.map(Runtime.runFork) ) @@ -35,7 +35,7 @@ export const t = initTRPC.create() // ) const testRouter = Effect.gen(function*() { - const run = yield* TRPCEffectRunner + const run = yield* TRPCEffectRuntime return t.router({ // test1: t.procedure.query( diff --git a/packages/server/src/index.ts b/packages/server/src/index.ts index d27f08f..70a297c 100644 --- a/packages/server/src/index.ts +++ b/packages/server/src/index.ts @@ -3,8 +3,8 @@ import { Todo } from "@todo-tests/common/data" import { Identifiable } from "@todo-tests/common/traits" import { Array, Duration, Effect, Fiber, Layer, Option, Stream } from "effect" import { MainLive } from "./Main" +import { TRPCEffectRuntimeLive } from "./TRPCEffectRuntime" import { TodoRepository, createDefaultTodos } from "./TodoRepository" -import { TRPCEffectRunnerLive } from "./trpc" const watchTodoChanges = Effect.gen(function*() { @@ -58,7 +58,7 @@ const main = Effect.gen(function*() { const runnableMain = main.pipe( Effect.provide( Layer.mergeAll( - TRPCEffectRunnerLive, + TRPCEffectRuntimeLive, MainLive, ) )