Implement and compose Effect-TS sinks to consume streams and produce results.
npx skills add https://github.com/andrueandersoncs/claude-skill-effect-ts --skill sinks
Please help me install this Agent Skill. Skill: Sinks Source: https://github.com/andrueandersoncs/claude-skill-effect-ts/tree/main/skills/sinks Command: npx skills add https://github.com/andrueandersoncs/claude-skill-effect-ts --skill sinks
The Sinks skill helps developers efficiently consume streams by providing idiomatic patterns for Effect-TS sinks, enabling reliable aggregation and side-effect processing without leaking resources.
High-intent search queries and answers about installing and using this skill.
You aggregate stream data in Effect-TS by running streams through sinks like collectAll, sum, or fold to consume emissions and produce a single aggregated result.
A sink in Effect-TS stream processing is a consumer that takes a stream of values and reduces them into a single result, enabling reliable aggregation and side-effect processing without leaking resources.
You compose multiple sinks for complex data pipelines in TypeScript by combining them with operators like map, dimap, and zip to transform and pair sink outputs within the Effect-TS ecosystem.
Yes, you can use Effect-TS sinks for logging and batch processing by applying real-world sink patterns such as foreach and fold to handle side-effects and process stream chunks efficiently.
To run a simple Effect-TS stream with a sink, you pipe a stream into Stream.run and pass a sink, such as Stream.make(1, 2, 3).pipe(Stream.run(Sink.sum)) to consume the values.
Yes, Effect-TS provides built-in sinks for folding stream values, allowing you to apply fold patterns to accumulate stream emissions into a computed result while managing resources safely.
andrueandersoncsCreate and transform Effect Streams for asynchronous data processing in TypeScript.
scotttrinhImplement deterministic Effect-TS Streams and Sinks patterns for batching and event logging.
mpsuesserBuild pull-based streaming pipelines with Effect Stream primitives and backpressure.
scotttrinhDesign and run Effect-TS streams for lazy, composable data processing.
