Tags: vladimirvivien/automi
Tags
feat: Add ChanSink for sending stream items to a Go channel (#41) This commit introduces a new sink type, `ChanSink`, to the `sinks` package. The `ChanSink` allows streaming data from an Automi pipeline directly into a Go channel. Key features: - Generic type `ChanSink[T any]` for flexibility with different data types. - Constructor `Chan[T any]()` to initialize the channel for the sink with the specified type. - Gracefully handles input channel closure and context cancellation. --------- Co-authored-by: google-labs-jules[bot] <161369871+google-labs-jules[bot]@users.noreply.github.com>
Automi project rewrite with Go generic types (#39) This patch is a complete rewrite of the Automi project with the support of generic types to create and compose Automi streams. This rewrite is not backward compatible with previous version of the project. Please see documentation and examples for new API changes. Happy streaming!