channels

package

v0.0.3 Latest Latest Go to latest Published: Jul 19, 2022 License: MIT Imports: 3 Imported by: 0

Details

This section is empty.

This section is empty.

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.

func ProcessWithContext[T any](ctx context.Context, in <-chan T, fn func(ctx context.Context, 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.