github.com/vladimirvivien/automi

What's Changed

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 = append(receivedData, data)
}

See documentation for detail.

• feat: Add ChanSink for sending stream items to a Go channel by @vladimirvivien in #41

Full Changelog: v0.2.0...v0.2.1

v0.2.0 - A project reboot with Go generics

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.

Key changes

• Type safety with generics: Leverages Go's generics for compile-time verification of operation types
• Simplified API: Ability to build complex stream pipelines with simplified components
• Built-in operators: As before, this rewrite provides a large set of built-in operators and other components
• Examples: New companion repository with large number of examples

See the project's documentation for detail discussion of the changes to the API.

License

The project license has been updated to MIT.

Previous version

The previous version of the project has been moved to branch v0.1.0-automi-reflection.