Subscribable

packages/effect-fc/src/types/Subscribable.ts

@@ -0,0 +1,24 @@
+import { Effect, Effectable, Readable, Stream, Subscribable } from "effect"
+
+
+class SubscribableImpl<A, E, R>
+extends Effectable.Class<A, E, R> implements Subscribable.Subscribable<A, E, R> {
+    readonly [Readable.TypeId]: Readable.TypeId = Readable.TypeId
+    readonly [Subscribable.TypeId]: Subscribable.TypeId = Subscribable.TypeId
+
+    constructor(
+        readonly get: Effect.Effect<A, E, R>,
+        readonly changes: Stream.Stream<A, E, R>,
+    ) {
+        super()
+    }
+
+    commit() {
+        return this.get
+    }
+}
+
+export const make = <A, E, R>(values: {
+    readonly get: Effect.Effect<A, E, R>
+    readonly changes: Stream.Stream<A, E, R>
+}): Subscribable.Subscribable<A, E, R> => new SubscribableImpl(values.get, values.changes)

packages/effect-fc/src/types/index.ts

@@ -1,3 +1,4 @@
 export * as PropertyPath from "./PropertyPath.js"
 export * as SetStateAction from "./SetStateAction.js"
+export * as Subscribable from "./Subscribable.js"
 export * as SubscriptionSubRef from "./SubscriptionSubRef.js"

packages/example/src/todo/Todo.tsx

@@ -54,7 +54,7 @@ export class Todo extends Component.makeUntraced(function* Todo(props: TodoProps
     // eslint-disable-next-line react-hooks/exhaustive-deps
     ), [props._tag, props._tag === "edit" ? props.id : undefined])
 
-    const [index, size] = yield* useSubscribe(indexRef, state.sizeRef)
+    const [index, size] = yield* useSubscribe(indexRef, state.sizeSubscribable)
 
     const StringTextAreaInputFC = yield* StringTextAreaInput
     const OptionalDateTimeInputFC = yield* OptionalDateTimeInput

packages/example/src/todo/TodosState.service.ts

@@ -2,7 +2,7 @@ import { Todo } from "@/domain"
 import { KeyValueStore } from "@effect/platform"
 import { BrowserKeyValueStore } from "@effect/platform-browser"
 import { Chunk, Console, Effect, Option, Schema, Stream, SubscriptionRef } from "effect"
-import { SubscriptionSubRef } from "effect-fc/types"
+import { Subscribable } from "effect-fc/types"
 
 
 export class TodosState extends Effect.Service<TodosState>()("TodosState", {
@@ -32,7 +32,11 @@ export class TodosState extends Effect.Service<TodosState>()("TodosState", {
         )
 
         const ref = yield* SubscriptionRef.make(yield* readFromLocalStorage)
-        const sizeRef = SubscriptionSubRef.makeFromPath(ref, ["length"])
+
+        const sizeSubscribable = Subscribable.make({
+            get: Effect.andThen(ref, Chunk.size),
+            get changes() { return Stream.map(ref.changes, Chunk.size) },
+        })
 
         yield* Effect.forkScoped(ref.changes.pipe(
             Stream.debounce("500 millis"),
@@ -43,7 +47,7 @@ export class TodosState extends Effect.Service<TodosState>()("TodosState", {
             Effect.ignore,
         ))
 
-        return { ref, sizeRef } as const
+        return { ref, sizeSubscribable } as const
     }),
 
     dependencies: [BrowserKeyValueStore.layerLocalStorage],