This commit is contained in:
Julien Valverdé
2024-07-12 03:57:41 +02:00
parent a0382a2427
commit 5edab3405b

View File

@@ -25,7 +25,7 @@ export const todosRouter = Effect.gen(function*() {
changes: procedure changes: procedure
.subscription(({ ctx }) => .subscription(({ ctx }) =>
observable<readonly (typeof JsonifiableTodo.Encoded)[]>(emit => { 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 const todos = yield* TodoRepository
yield* todos.todos.changes.pipe( yield* todos.todos.changes.pipe(