channels

package

v0.1.0 Latest Latest Go to latest Published: Aug 2, 2022 License: MIT Imports: 2 Imported by: 0

Details

This section is empty.

This section is empty.

func Drain[T any](in <-chan T, fn func(in T))

Drain receives each value from an input channel and does something with it.

func Generate[T any](values ...T) <-chan T

Generate sends each value to the out channel.

func Merge[T any](in ...<-chan T) <-chan T

Merge sends each value from a list of input channels to the out channel.

func Process[T any](in <-chan T, fn func(in T) T) <-chan T

Process works on each value from an input channel and sends the result to an output channel.

This section is empty.