Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

pipeline

package module

Go to main page

Versions in this module

v0

v0.0.12

Mar 25, 2023

Changes in this version

+ func Map(ctx context.Context, in chan I, f func(I) (O, error)) (chan O, chan error)

v0.0.11

Mar 25, 2023

Changes in this version

+ func FlatMap(ctx context.Context, in chan []T) chan T

v0.0.10

Mar 19, 2023

v0.0.9

Mar 19, 2023

Changes in this version

+ func Collect(ctx context.Context, ch chan T) []T

v0.0.8

Mar 19, 2023

Changes in this version

+ func Aggregate5(ctx context.Context, in1 Aggregator[I1, K], in2 Aggregator[I2, K], ...) (chan A, chan error)

v0.0.7

Mar 18, 2023

Changes in this version

+ func StaticKeyFn(i T) int

v0.0.6

Mar 18, 2023

Changes in this version

+ func TestAggregate3Error(t *testing.T)

v0.0.5

Mar 18, 2023

Changes in this version

+ func Chan(f func() (I, error)) (chan I, chan error)

v0.0.4

Mar 18, 2023

Changes in this version

+ func PassingFn(in In) (In, error)

v0.0.3

Mar 18, 2023

Changes in this version

+ func Split(ctx context.Context, chIn <-chan In, sa1 *stepaction.StepAction[In, O1], ...) (chan O1, chan O2, chan error)

v0.0.2

Mar 18, 2023

Changes in this version

+ func Aggregate(ctx context.Context, in1 Aggregator[I1, K], in2 Aggregator[I2, K], ...) chan A

+ func Aggregate3(ctx context.Context, in1 Aggregator[I1, K], in2 Aggregator[I2, K], ...) chan A

+ func Multicast(ctx context.Context, chIn <-chan In, sa1 *stepaction.StepAction[In, O1], ...) (chan O1, chan O2, chan error)

+ func TestAggregate3(t *testing.T)

+ type Aggregator struct

+ Ch chan I

+ KeyFn func(I) K

v0.0.1

Mar 17, 2023

Changes in this version

+ func Merge(ctx context.Context, chs ...chan T) <-chan T

+ func Source(ctx context.Context, in []In) (chan In, chan error)

+ func Step(ctx context.Context, chIn <-chan In, ...) (chan Out, chan error)

+ type StepOption func(*stepConfig)

+ func WithLimit(l int64) StepOption