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

cpr

package

Go to main page

Versions in this module

v0

v0.1.2

Sep 12, 2024

Changes in this version

+ func FanIn[T any](f func(context.Context, chan<- T) error) (<-chan T, func(context.Context) error)

+ func ForEach[T any](ctx context.Context, ch <-chan T, f func(T) error) error

+ func Produce[T any](f func(context.Context, chan<- T) error) (<-chan T, func(context.Context) error)

+ func Seq[T any](ctx context.Context, ts []T, fs ...func(T) error) ([]T, error)

v0.1.1

Apr 7, 2023

Changes in this version

+ func Consume(ctx context.Context, ch <-chan T, f func(T) error) error

v0.0.16

Sep 8, 2022

Changes in this version

+ func ForAll(ts []T, f func(T)) func()

+ func Parallel(fs ...func()) func()

+ type Pipeline interface

+ Process func(context.Context) error

+ func Connect(src Source[T], snk Sink[T]) Pipeline

type Source

+ func Compose(s Source[T], p Processor[T, U]) Source[U]

v0.0.15

Apr 7, 2022

Changes in this version

+ func Demultiplex(inChs ...<-chan T) chan T

+ func Get(ch <-chan T, errCh <-chan error) (T, bool, error)

+ func Pop(ctx context.Context, ch <-chan T) (T, bool, error)

+ func Push(ctx context.Context, ch chan<- T, ts ...T) error

+ func RunTestEngine(ctx context.Context, ps Processor[T], ts ...T) ([]T, error)

+ type Collector struct

+ Result []T

+ func (c *Collector[T]) Sink(ctx context.Context, inCh <-chan T) error

+ type Engine struct

+ Processors []Processor[T]

+ Sink Sink[T]

+ Source Source[T]

+ func (eng *Engine[T]) Add(p Processor[T])

+ func (eng *Engine[T]) Process(ctx context.Context) error

+ type Processor interface

+ Process func(context.Context, <-chan T, chan<- T) error

+ type Producer struct

+ Items []T

+ func (p *Producer[T]) Source(ctx context.Context, outCh chan<- T) error

+ type Sink interface

+ Sink func(context.Context, <-chan T) error

+ type Source interface

+ Source func(context.Context, chan<- T) error