Streams
This skill should be used when the user asks about "Effect Stream", "Stream.from", "Stream.map", "Stream.filter", "Stream.run", "streaming data", "async iteration", "Sink", "Channel", "Stream.concat", "Stream.merge", "backpressure", "Stream.fromIterable", "chunked processing", "real-time data", or needs to understand how Effect handles streaming data processing.
npx skills add majiayu000/claude-skill-registry --skill streams-andrueandersoncs-claude-skill-effect --agent claude-code
Same command for any agent — swap --agent for codex, cursor, copilot.
Weekly change comes from our own snapshots, not the repository page — it measures attention, not adoption.
# Streams in Effect ## Overview Effect Streams provide: - **Lazy evaluation** - Elements produced on demand - **Resource safety** - Automatic cleanup - **Backpressure** - Producer/consumer coordination - **Composition** - Transform, filter, merge streams - **Error handling** - Typed errors in stream pipeline ```typescript Stream<A, E, R> // Produces values of type A // May fail with error E // Requires environment R ``` ## Creating Streams ### From Values ```typescript import { Stream } from "effect" const numbers = Stream.make(1, 2, 3, 4, 5) const fromArray = Stream.fromIterable([1, 2, 3]) const empty = Stream.empty const single = Stream.succeed(42) const infinite = Stream.iterate(1, (n) => n + 1) ``` ### From Effects ```typescript const fromEffect = Stream.fromEffect(fetchData()) const polling = Stream.repeatEffect(checkStatus()) const scheduled = Stream.repeatEffectWithSchedule( checkStatus(), Schedule.spaced("5 seconds") ) ``` ### From Async Sources ```typescript // From async iterable const fromAsyncIterable = Stream.fromAsyncIterable( asyncGenerator(), (error) => new StreamError({ cause: error }) ) // From callback/event emitter const fromCallback = Stream.async<number, never
- Overview
- Creating Streams
- From Values
- From Effects
- From Async Sources
- Generating Streams
- Transforming Streams
- map - Transform Elements
- filter - Select Elements
- flatMap - Nested Streams
- take/drop
- Combining Streams
- concat - Sequential
- merge - Interleaved
What does the Streams skill do?
This skill should be used when the user asks about "Effect Stream", "Stream.from", "Stream.map", "Stream.filter", "Stream.run", "streaming data", "async iteration", "Sink", "Channel", "Stream.concat", "Stream.merge", "backpressure", "Stream.fromIterable", "chunked processing", "real-time data", or needs to understand how Effect handles streaming data processing.
How do I install it?
Run `npx skills add majiayu000/claude-skill-registry --skill streams-andrueandersoncs-claude-skill-effect --agent claude-code` — it drops the skill into your project so the agent can pick it up. Swap the --agent value for codex, cursor or copilot if you use one of those.
Where does this skill come from?
From majiayu000/claude-skill-registry, a repository with 534 stars. We read it straight from the repository tree rather than a submitted listing, so what you see here is what is actually published.
Is a popular skill a good skill?
Not necessarily. Stars measure attention, not adoption — a repository can trend for a week and be abandoned. That is why we show the weekly change from our own snapshots next to the total, instead of a single flattering number.