skills.rest
scotttrinh
scotttrinhCOMMUNITY
Explore all skills by this author →
WebsiteGitHub

effect-patterns-streams

Implement Effect-TS streaming patterns for real-time data flows in Node.js.

Updated Jan 24, 2026
Search Tags:#patterns#effect-ts#stateful#streams#backpressure#windowing
One-click install
npx skills add https://github.com/scotttrinh/nook --skill effect-patterns-streams-scotttrinh
Or copy as Structured Prompt for Agent▼
Please help me install this Agent Skill.
Skill: effect-patterns-streams
Source: https://github.com/scotttrinh/nook/tree/main/.agents/skills/effect-patterns-streams
Command: npx skills add https://github.com/scotttrinh/nook --skill effect-patterns-streams-scotttrinh

SYSTEM DOCUMENTATION & REQUIREMENTS

What problem does it solve?

This Skill delivers a reusable set of patterns for building robust streaming pipelines with Effect-TS streams, enabling developers to compose, optimize, and reason about data flows.

Core Features & Use Cases

  • Pattern library: Map/filter, merge/concat, backpressure, scan/fold, grouping/windowing, and resource management patterns demonstrated with concrete examples.
  • Real-world workflows: Ideal for event processing, log analytics, and real-time dashboards that require lazy evaluation, modular composition, and safe resource handling.
  • Use Case: Imagine a system processing multiple event streams with backpressure and per-key grouping to compute live metrics.

Quick Start

Run the TypeScript example that demonstrates map and filter on a sample stream.

Frequently Asked Questions about effect-patterns-streams

High-intent search queries and answers about installing and using this skill.

FAQPage Schema
How do I handle backpressure in Effect-TS streams?▼

Backpressure in Effect-TS streams is managed using built-in strategies that control data flow rates, preventing producers from overwhelming consumers in real-time pipelines. This Skill provides patterns for implementing safe backpressure handling.

What is the best way to group events by key in an Effect-TS stream?▼

Grouping events by key in an Effect-TS stream uses windowing and grouping patterns to partition data flows, enabling per-key aggregations for live metrics. This Skill demonstrates stateful scans and windowing for these analytics use cases.

How do I merge or concat multiple streams in Effect-TS?▼

Merging or concatenating multiple streams in Effect-TS combines distinct event sources into a single flow, enabling modular composition for complex data pipelines. This Skill provides map, filter, merge, and concat patterns for composing reliable streaming workflows.

Do I need Node.js to build streaming pipelines with Effect-TS?▼

Building streaming pipelines with Effect-TS requires TypeScript, the Effect library, and a Node.js environment to run the examples. This Skill targets developers implementing data flows in that specific runtime environment.

When should I use stateful scans in Effect-TS streams?▼

Stateful scans in Effect-TS streams are used when processing real-time data flows requires accumulating state across stream events, such as computing live metrics or running log analytics. This Skill provides patterns for maintaining state safely during stream processing.

Related Skills

Explore More Software Engineering Skills→
tomsiwiktomsiwik
1

effect-patterns-testing

Test Effect-TS applications with deterministic patterns for services and time.

Community
Intermediate
zangxin75zangxin75

dual-stream-architecture

Publishes events to both Kafka and Redis for durable and real-time delivery.

Community
Advanced
scotttrinhscotttrinh

effect-patterns-building-data-pipelines

Build TypeScript data pipelines with Effect-TS stream patterns.

Community
Intermediate
reactiveuireactiveui
9

reactiveui-primitives

Provide a LINQ-like reactive programming library for .NET with minimal dependencies.

Official
Advanced