v0.7.0

Features

• add *MapOp.ConcurrentPreservingOrder

Fixes

• avoid cases where Fanout operator gets stuck

Full Changelog: v0.6.2...v0.7.0

v0.6.2

Documentation

• update documentation to describe overview of the framework
• add a link to docs on pkg.go.dev

Full Changelog: v0.6.1...v0.6.2

v0.6.1

Fixes

• fix case where a last few outputs are dropped

Full Changelog: v0.6.0...v0.6.1

v0.6.0

Fixes

• [BREAKING] avoid closing output channel automatically by task (942b14f)

v0.5.0

Features

• add source.FromChan
• add sink.ToChan

Fixes

• panic when running invalid concurrent pipe/sink
• return an error when no matching flow is found when running registry

Full Changelog: v0.4.0...v0.5.0

v0.4.0

Fixes

• abort upstream tasks when a downstream task is finished early

Features

• add pipe.Take
• add pipe.FlattenSlice
• add pipe.Select

Full Changelog: v0.3.0...v0.4.0

v0.3.0

Features

• add taskfn.SliceToSlice, taskfn.SourceToSlice and taskfn.SliceToSink
• add task.FromFn to provide a way to reuse the core logic
• support task options for source
• support task options for sink
• support task options for pipe
• add Abort RPC to Communicator service
• call Abort RPC when Pull operation has finished
• support task options for source operators
• support task options for sink operators
• support task options for pipe operators
• add functionality to assign task name for debugging purpose
• add pipe.Batch
• support task options for pipe.Tap

Fixes

• resolve case where internal/channel.DuplicateOutChan gets stuck

Full Changelog: v0.2.0...v0.3.0

v0.2.0

Changes

• [BREAKING] Rename task.Feed to task.Emit

Docs

• Update docs for Task.Run

Full Changelog: v0.1.1...v0.2.0

v0.1.1

• Add task.Feed to avoid getting stuck when its downstream is broken with an error

Full Changelog: v0.1.0...v0.1.1

v0.1.0

Carbo initial release 🎉