automi:Go(alpha)的流处理API 源码

Go(Alpha)的数据流处理API Automi是用于使用惯用的Go处理数据流的API。 使用Automi,程序可以通过组合应用于流的每个元素的操作阶段来处理数据块的流。 概念 Automi API用四个原语表达流,包括: 发射器:可以发射流元素的内存,网络或文件资源 流:代表流式传输数据元素的管道 流操作:可以附加到流上以处理流元素的代码 收集器:可以收集流式数据的内存,网络或文件资源。 Automi流在内部使用Go通道来路由数据。 这意味着Automi流将自动支持诸如缓冲,自动背压排队和并发安全性之类的功能。 使用Automi 现在,让我们探索一些示例,看看使用Automi传输