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(