Streamlines data consumption and aggregation within the Effect-TS ecosystem using specialized Sink patterns.
This skill provides comprehensive guidance and implementation patterns for Effect Sinks, the essential counterpart to Streams in the Effect-TS library. It enables developers to efficiently process, aggregate, and transform stream data through built-in sinks like collectAll, sum, and fold, as well as sophisticated custom-built consumers. Whether you are implementing batched database inserts, building complex aggregation pipelines, or managing concurrent data processing, this skill provides the idiomatic TypeScript patterns needed to handle stream termination, leftovers, and result production with full type safety and error handling.
主な機能
01Guidance on creating custom sinks using Sink.make and Sink.fromPush
02Implementation patterns for built-in sinks like collectAll, sum, and fold
033 GitHub stars
04Detailed handling of stream leftovers and unconsumed data elements
05Advanced sink composition using zip, race, and transformation operations
06Concurrent processing strategies with Sink.zipPar and chunked folding
ユースケース
01Building high-performance batched database insert pipelines from stream data
02Implementing complex file system or API side-effects during stream consumption
03Creating multi-metric aggregation systems that process streams in a single pass
