parapipe

Dec 13, 2024

Changes in this version

+ type Callback func(msg I) (output O, proceed bool)

type Pipeline

+ func Attach[I, T, O any](left *Pipeline[I, T], right *Pipeline[T, O]) *Pipeline[I, O]

May 2, 2021

Changes in this version

type Pipeline

+ func (p *Pipeline) Close()

+ func (p *Pipeline) Push(v interface{})

Apr 20, 2021

Changes in this version

+ type Config struct

+ Concurrency int

+ ProcessErrors bool

Apr 10, 2021

Changes in this version

+ type Job func(msg interface{}) interface

+ type Pipeline struct

+ func NewPipeline(concurrency int) *Pipeline

+ func (p *Pipeline) In() chan<- interface{}

+ func (p *Pipeline) Out() <-chan interface{}

+ func (p *Pipeline) Pipe(job Job) *Pipeline