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 https://github.com/vladimirvivien/automi/pull/41

Full Changelog: https://github.com/vladimirvivien/automi/compare/v0.2.0...v0.2.1