From 7ea85ae2ae87d0240c4df01836c11e590c346c08 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Julien=20Valverd=C3=A9?= Date: Sat, 29 Jun 2024 00:13:26 +0200 Subject: [PATCH] Tests --- packages/server/src/index.ts | 13 ++++++++++--- 1 file changed, 10 insertions(+), 3 deletions(-) diff --git a/packages/server/src/index.ts b/packages/server/src/index.ts index e780f40..dbb5a04 100644 --- a/packages/server/src/index.ts +++ b/packages/server/src/index.ts @@ -1,14 +1,21 @@ import { BunRuntime } from "@effect/platform-bun" import { Todo } from "@todo-tests/common/data" -import { Array, Effect } from "effect" +import { Array, Console, Effect, Stream } from "effect" import { TodoRepository, TodoRepositoryLive, createDefaultTodos } from "./TodoRepository" +const watchTodoChanges = Effect.gen(function*() { + const todos = yield* TodoRepository + yield* Stream.runForEach(todos.todos.changes, todos => Console.log(`Todos changed: ${ todos }`)) +}) + + const main = Effect.gen(function*() { + const watcher = yield* Effect.fork(watchTodoChanges) yield* createDefaultTodos const todos = yield* TodoRepository - console.log(yield* todos.todos.get) + // console.log(yield* todos.todos.get) const secondTodo = yield* yield* todos.todos.get.pipe( Effect.map(Array.get(1)) @@ -19,7 +26,7 @@ const main = Effect.gen(function*() { }) yield* todos.update(secondTodoModified) - console.log(yield* todos.todos.get) + // console.log(yield* todos.todos.get) }) const runnableMain = main.pipe(