Todos refactoring

packages/example/src/todos/services/TodosState.ts

@@ -7,15 +7,8 @@ import { Chunk, Context, Effect, identity, Layer, ParseResult, Ref, Schema, Stre
 
 export class TodosState extends Context.Tag("TodosState")<TodosState, {
     readonly todos: SubscriptionRef.SubscriptionRef<Chunk.Chunk<Todo.Todo>>
-
     readonly load: Effect.Effect<void, PlatformError | ParseResult.ParseError>
     readonly save: Effect.Effect<void, PlatformError | ParseResult.ParseError>
-
-    readonly prepend: (todo: Todo.Todo) => Effect.Effect<void>
-    readonly replace: (index: number, todo: Todo.Todo) => Effect.Effect<void>
-    readonly remove: (index: number) => Effect.Effect<void>
-    // readonly moveUp: (index: number) => Effect.Effect<void, Cause.NoSuchElementException>
-    // readonly moveDown: (index: number) => Effect.Effect<void, Cause.NoSuchElementException>
 }>() {}
 
 
@@ -41,30 +34,11 @@ export const make = (key: string) => Layer.effect(TodosState, Effect.gen(functio
     )
 
     const todos = yield* SubscriptionRef.make(yield* readFromLocalStorage)
-
     const load = Effect.flatMap(readFromLocalStorage, v => Ref.set(todos, v))
     const save = Effect.flatMap(todos, writeToLocalStorage)
 
-    const prepend = (todo: Todo.Todo) => Ref.update(todos, Chunk.prepend(todo))
-    const replace = (index: number, todo: Todo.Todo) => Ref.update(todos, Chunk.replace(index, todo))
-    const remove = (index: number) => Ref.update(todos, Chunk.remove(index))
-
-    // const moveUp = (index: number) => Effect.gen(function*() {
-
-    // })
-
     // Sync changes with local storage
-    yield* Effect.forkScoped(todos.changes.pipe(
-        Stream.debounce("500 millis"),
-        Stream.runForEach(writeToLocalStorage),
-    ))
+    yield* Effect.forkScoped(Stream.runForEach(todos.changes, writeToLocalStorage))
 
-    return {
-        todos,
-        load,
-        save,
-        prepend,
-        replace,
-        remove,
-    }
+    return { todos, load, save }
 }))