effect-patterns-streams-sinks

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

1|1|Updated Feb 12, 2026
One-click install
npx skills add https://github.com/tomsiwik/dojocho --skill effect-patterns-streams-sinks-tomsiwik
Or copy as Structured Prompt for Agent
Please help me install this Agent Skill.
Skill: effect-patterns-streams-sinks
Source: https://github.com/tomsiwik/dojocho/tree/main/dojos/effect-ts/skills/effect-patterns-streams-sinks
Command: npx skills add https://github.com/tomsiwik/dojocho --skill effect-patterns-streams-sinks-tomsiwik

SYSTEM DOCUMENTATION & REQUIREMENTS

What problem does it solve?

This Skill helps developers effectively manage and process data streams using Effect-TS, providing robust patterns for common asynchronous data flow challenges.

Core Features & Use Cases

  • Efficient Data Handling: Learn patterns for batching, error handling, and reliable data persistence with streams.
  • Event Sourcing & Queues: Implement patterns for writing to event logs and publishing to message queues.
  • Use Case: When processing a large volume of sensor data, use this Skill to batch readings and reliably send them to a message queue for further analysis, ensuring no data is lost even if the queue experiences temporary issues.

Quick Start

Use the effect-patterns-streams-sinks skill to batch insert stream records into a database.

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 handle asynchronous stream batching in Effect-TS?

To handle asynchronous stream batching in Effect-TS, use the provided patterns for grouping stream records into batches. This approach allows you to efficiently process large volumes of data, like sensor readings, before persisting them to a database or publishing to a queue.

What is the best way to build fault-tolerant data pipelines with Effect-TS streams?

Building fault-tolerant data pipelines with Effect-TS streams involves implementing resilient processing logic that ensures no data is lost during temporary queue failures. The Skill provides robust patterns for error handling and reliable data persistence within your application.

Can I use Effect-TS streams for event sourcing and message queue integration?

Yes, you can use Effect-TS streams for event sourcing and message queue integration. The Skill provides specific patterns for writing to event logs and publishing asynchronous data to message queues for downstream analysis.

How do I prevent data loss when writing to message queues in Effect-TS?

To prevent data loss when writing to message queues in Effect-TS, apply resilient stream processing patterns that handle temporary queue failures. This ensures your data pipelines remain robust and fault-tolerant during connection interruptions.

Does this Skill provide patterns for batch inserting stream records into a database?

Yes, this Skill provides patterns for batch inserting stream records into a database. It addresses efficient data handling by offering techniques for batching, error handling, and reliable data persistence within your Effect-TS application.