Unclaimed project
Are you a maintainer of automi? Claim this project to take control of your public changelog and roadmap.
This release introduces the ChanSink. It allows streaming data, from an Automi pipeline, to be collected into a channel. Items in the channel can be accessed as shown below:
src := sources.Slice([][]string{ ... }
snk := sinks.Chan[[]string]()
strm := From(src)
strm.Into(snk)
...
var receivedData [][]string
for data := range snk.Get() {
receivedData =...
This version of Automi introduces type-safety for building efficient data stream processing pipelines. Using Go's generics, it provides a composable API that enables developers to process data streams with compile-time type checking, eliminating runtime errors common in reflection-based approaches.
Initial (re)release.