用途:该技能在用户询问 Effect Stream、Stream.from、Stream.map、Stream.filter、Stream.run、流式数据、异步数据源等主题时使用,帮助在 Effect 中构建和处理流。
主要能力:Effect Streams 提供惰性求值(按需产生元素)、资源安全(自动清理)、背压(生产者/消费者协调)、组合(转换、过滤、合并流)以及类型化错误处理。类型为 Stream<A, E, R>,产生 A 类型值,可能以 E 失败,需要环境 R。
创建方式:可从值创建(Stream.make、Stream.fromIterable、Stream.empty、Stream.succeed、Stream.iterate),从 Effect 创建(Stream.fromEffect、Stream.repeatEffect、Stream.repeatEffectWithSchedule),从异步源创建(Stream.fromAsyncIterable、Stream.async、Stream.fromQueue),以及生成(Stream.unfold、Stream.range、Stream.repeat)。
转换与组合:map、mapEffect(支持 concurrency 并行)、filter、filterEffect、flatMap、take/drop、takeWhile/dropWhile;组合可用 concat(顺序)、merge/mergeAll(交错)、zip/zipWith(配对)、interleave。
消费:runCollect、runHead、runFold、runForEach、runDrain,或通过 Sink 运行(Sink.sum、Sink.collectAll 等)。流按块处理,可用 grouped、mapChunks、rechunk。
错误与资源:catchAll、catchTag、retry、orElse 处理错误;acquireRelease、scoped 管理资源生命周期。常见模式包括批量处理、限流(throttle)、防抖(debounce)、时间窗口(groupedWithin)。
限制:资料未提供该技能的安装方式、收费、平台或效果信息,暂未提供。