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

effect-patterns-streams-sinks

Implement deterministic Effect-TS Streams and Sinks patterns for batching and event logging.

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

SYSTEM DOCUMENTATION & REQUIREMENTS

What problem does it solve?

This Skill provides reusable, deterministic patterns for streaming data with Effect-TS's Streams and Sinks.

Core Features & Use Cases

  • Pattern Library: Provides batching, event logging, message publishing, and fault-tolerant sinks for effect-ts streams.
  • Use Case: Build a streaming pipeline that batches data before database writes or publishes events to a queue.
  • Advanced Scenarios: Compose multiple sinks with fallbacks and retry strategies to achieve resilience in data processing.

Quick Start

Use the skill to implement a batched sink that collects records from a Stream and writes them to a database in bulk.

Frequently Asked Questions about effect-patterns-streams-sinks

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

FAQPage Schema
How do I batch data in an Effect-TS stream before writing to a database?▼

To batch data in an Effect-TS stream, you can use a batched sink that collects records from the stream and writes them in bulk. This pattern enables reliable, composable data pipelines for database writes.

What is the best way to add fault-tolerant fallbacks to Effect-TS streams?▼

Adding fault-tolerant fallbacks to Effect-TS streams involves composing multiple sinks with retry strategies. This approach achieves resilience in data processing by ensuring deterministic fallback behavior.

Can I use Effect-TS streams to publish events to a queue?▼

Yes, you can use Effect-TS streams to publish events to a queue. The stream patterns support message publishing, allowing you to build pipelines that forward streaming data to external queues.

How do Effect-TS sinks work for event logging in functional programming?▼

Effect-TS sinks work for event logging by consuming stream elements and applying deterministic patterns to log events. They enable explicit, composable data pipelines within TypeScript functional programming.

Related Skills

Explore More Software Engineering Skills→
andrueandersoncsandrueandersoncs
8

Streams

Create and transform Effect Streams for asynchronous data processing in TypeScript.

Community
Intermediate
PaulJPhilpPaulJPhilp
785

effect-patterns-streams-sinks

Compose Effect-TS streaming sinks for batching, persisting, and publishing data.

Community
Advanced
tomsiwiktomsiwik
1

effect-patterns-streams-sinks

Implement Effect-TS patterns for batching and publishing asynchronous data streams.

Community
Advanced
pluginagentmarketplacepluginagentmarketplace
5

rxjs-implementation

Implement RxJS observables and operators for Angular reactive data pipelines.

Community
Intermediate