channel

Jan 22, 2024

Changes in this version

+ func Filter[T any](input <-chan T, predicate Predicate[T]) <-chan T

+ func FromSlice[T any](slice []T) <-chan T

+ type Done chan struct

+ type Predicate func(T) bool

Dec 17, 2023

Changes in this version

+ func Beep[T any](in <-chan T) <-chan T

+ func Map[Input any, Output any](input <-chan Input, mapper func(Input) Output) <-chan Output

Jul 20, 2023

Changes in this version

+ func Closed(channel <-chan T) bool

+ func Limit(maximum int, input <-chan T, done chan struct{}) <-chan T

+ func Pipe(input <-chan T, output chan<- T)

+ func PipeWithCancel(input <-chan T, output chan<- T, done <-chan struct{})

+ func Reverse(input <-chan T, done <-chan struct{}) <-chan T

+ func Slice(channel <-chan T) []T