diff --git a/packages/effect-fc/src/Result.ts b/packages/effect-fc/src/Result.ts index b496ce7..2535395 100644 --- a/packages/effect-fc/src/Result.ts +++ b/packages/effect-fc/src/Result.ts @@ -217,8 +217,8 @@ export const unsafeForkEffect = Effect.fnUntraced(function* )) as Lens.SynchronizedRefLensImpl.SynchronizedRefWithInternals> const pubsub = yield* PubSub.unbounded>() - const state = Lens.make, never, never, never, never>({ - get get() { return Ref.get(ref.ref) }, + const state = Lens.make({ + get: Ref.get(ref.ref), get changes() { return Stream.unwrapScoped(Effect.map( Effect.all([Ref.get(ref.ref), Stream.fromPubSub(pubsub, { scoped: true })]),