effect-pubsub-event-bus

Build a typed event bus by defining a discriminated union with Schema.TaggedClass, creating a PubSub, and converting it to a Stream via Stream.fromPubSub. This enables strongly validated event payloads for service communication.

Manage PubSub subscription cleanup deterministically using Effect.forkScoped and finalizers. This ties the subscription lifecycle and PubSub shutdown to the owning Scope, preventing resource leaks when the scope ends.

Filter and map events in an Effect Stream subscription by applying stream operators to the Stream generated from Stream.fromPubSub. This composable approach enables reactive processing of typed event payloads.

Use an Effect Stream event bus over imperative callbacks when you need reactive, stream-first designs for inter-service domain events. It replaces messy callback lifecycles with composable streams and scoped fiber management.

Yes, Effect PubSub supports backpressure for stream-based subscribers. Converting the PubSub channel into a Stream via Stream.fromPubSub enables backpressure behavior alongside filtering and mapping operations.

Yes, you can use Schema.TaggedClass for discriminated union event modeling in Effect. It ensures publishers and subscribers agree on payload shape, providing strongly validated event payloads for your event bus.