Documentation
¶
Index ¶
- func Drain[T any](in <-chan T, fn func(in T))
- func Generate[T any](values ...T) <-chan T
- func Merge[T any](in ...<-chan T) (out chan T)
- func Multiplex[T any](in <-chan T, num int) (out []chan T)
- func Process[T any](in <-chan T, fn func(in T) T) chan T
- func Split[T any](in <-chan T, num int) (out []chan T)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func Drain ¶ added in v0.1.0
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 ¶
func Generate[T any](values ...T) <-chan T
Generate sends each value to the out channel.
func Merge ¶
func Merge[T any](in ...<-chan T) (out chan T)
Merge sends each value from a list of input channels to the out channel.
func Multiplex ¶ added in v0.1.16
Multiplex sends each value from an input channel to every output channel.
Types ¶
This section is empty.
Source Files
Click to show internal directories.
Click to hide internal directories.