v0.3.0
Features
- add
taskfn.SliceToSlice
,taskfn.SourceToSlice
andtaskfn.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