From 6bc07d5b2a0ba984ef53019ddd41a749b6085c1e Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Julien=20Valverd=C3=A9?= Date: Thu, 8 May 2025 05:59:36 +0200 Subject: [PATCH] Tests --- packages/reffuse/src/tests.ts | 17 +++++++++++++++++ 1 file changed, 17 insertions(+) create mode 100644 packages/reffuse/src/tests.ts diff --git a/packages/reffuse/src/tests.ts b/packages/reffuse/src/tests.ts new file mode 100644 index 0000000..cbb2db7 --- /dev/null +++ b/packages/reffuse/src/tests.ts @@ -0,0 +1,17 @@ +import { Effect, Exit, PubSub, Scope, Stream } from "effect" + + +await Effect.gen(function*() { + const scope = yield* Scope.make() + + const pubsub = yield* PubSub.unbounded() + console.log(yield* PubSub.isShutdown(pubsub)) + const stream = yield* Stream.fromPubSub(pubsub, { scoped: true, shutdown: true }).pipe( + Effect.provideService(Scope.Scope, scope) + ) + + yield* Scope.close(scope, Exit.void) + console.log(yield* PubSub.isShutdown(pubsub)) +}).pipe( + Effect.runPromise, +)