From 5edab3405bb8d6134635a0d94bdc2e0ffdb7c7d9 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?Julien=20Valverd=C3=A9?= <julien.valverde@mailo.com>
Date: Fri, 12 Jul 2024 03:57:41 +0200
Subject: [PATCH] Fix

---
 packages/server/src/rpc/routers/todos.ts | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/packages/server/src/rpc/routers/todos.ts b/packages/server/src/rpc/routers/todos.ts
index 20637c2..aae03c6 100644
--- a/packages/server/src/rpc/routers/todos.ts
+++ b/packages/server/src/rpc/routers/todos.ts
@@ -25,7 +25,7 @@ export const todosRouter = Effect.gen(function*() {
         changes: procedure
             .subscription(({ ctx }) =>
                 observable<readonly (typeof JsonifiableTodo.Encoded)[]>(emit => {
-                    const watcher = Runtime.runFork(ctx.runtime)(Effect.gen(function*() {
+                    const watcher = ctx.fork(Effect.gen(function*() {
                         const todos = yield* TodoRepository
 
                         yield* todos.todos.changes.pipe(