cpr

Documentation

Overview

Package cpr contains concurrency primitives.

Index

• func Demultiplex[T any](inChs ...<-chan T) chan T
• func FanIn[T any](f func(context.Context, chan<- T) error) (<-chan T, func(context.Context) error)
• func ForAll[T any](ts []T, f func(T)) func()
• func ForEach[T any](ctx context.Context, ch <-chan T, f func(T) error) error
• func Parallel(fs ...func()) func()
• func Pop[T any](ctx context.Context, ch <-chan T) (T, bool, error)
• func Produce[T any](f func(context.Context, chan<- T) error) (<-chan T, func(context.Context) error)
• func Push[T any](ctx context.Context, ch chan<- T, ts ...T) error
• func Seq[T any](ctx context.Context, ts []T, fs ...func(T) error) ([]T, error)

Functions

func Demultiplex

func Demultiplex[T any](inChs ...<-chan T) chan T

Demultiplex demultiplexes the given channels.

func FanIn

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

func ForAll

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

func ForEach

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

func Parallel

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

func Pop

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

Pop returns a new T from the ch. It returns a boolean which indicates whether the channel is still open. The error indicates whether the context has been canceled.

func Produce

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

func Push

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

Push tries to push a T to the ch. The error indicates whether the context has been canceled.

func Seq

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