From 4b9bfd06379b631e5e76596b91861d00587bbf70 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Julien=20Valverd=C3=A9?= Date: Mon, 5 May 2025 21:52:55 +0200 Subject: [PATCH] Stream PubSub --- packages/reffuse/src/ReffuseNamespace.ts | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/packages/reffuse/src/ReffuseNamespace.ts b/packages/reffuse/src/ReffuseNamespace.ts index 56d5e54..f1717e6 100644 --- a/packages/reffuse/src/ReffuseNamespace.ts +++ b/packages/reffuse/src/ReffuseNamespace.ts @@ -1,4 +1,4 @@ -import { Chunk, type Context, Effect, ExecutionStrategy, Exit, type Fiber, flow, type Layer, Match, Option, pipe, Pipeable, Queue, Ref, Runtime, Scope, Stream, SubscriptionRef } from "effect" +import { Chunk, type Context, Effect, ExecutionStrategy, Exit, type Fiber, flow, type Layer, Match, Option, pipe, Pipeable, PubSub, Ref, Runtime, Scope, Stream, SubscriptionRef } from "effect" import * as React from "react" import * as ReffuseContext from "./ReffuseContext.js" import * as ReffuseRuntime from "./ReffuseRuntime.js" @@ -474,11 +474,11 @@ export abstract class ReffuseNamespace { this: ReffuseNamespace, values: A, ): Stream.Stream { - const [queue, stream] = this.useMemo(() => Queue.unbounded().pipe( - Effect.map(queue => [queue, Stream.fromQueue(queue)] as const) + const [pubsub, stream] = this.useMemo(() => PubSub.unbounded().pipe( + Effect.map(pubsub => [pubsub, Stream.fromPubSub(pubsub)] as const) ), []) - this.useEffect(() => Queue.offer(queue, values), values) + this.useEffect(() => PubSub.publish(pubsub, values), values) return stream }