Documentation
¶
Index ¶
- func Batch[T any](ch <-chan T, size int) <-chan []T
- func FanIn[T any](streams ...<-chan T) <-chan T
- func FanOut[T any](ch chan T, size int, ordered bool) []<-chan T
- func Filter[IN any](fn func(IN) bool) func(<-chan IN) <-chan IN
- func Parallel[IN, OUT any](stream <-chan IN, fn func(IN) OUT, count int) <-chan OUT
- func Pipeline[IN, OUT any](fn func(IN) OUT) func(<-chan IN) <-chan OUT
- func Split[IN, OUT1, OUT2 any](in <-chan IN, fn func(IN) (OUT1, OUT2)) (<-chan OUT1, <-chan OUT2)
- type Future
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func FanIn ¶
func FanIn[T any](streams ...<-chan T) <-chan T
FanIn merges multiple channels of input values into a single channel of output values.
func FanOut ¶
FanOut splits a channel of input values into multiple channels of output values in a round-robin fashion.
func Filter ¶ added in v1.1.4
Filter filtered channel values by applying a function to each input value.
func Parallel ¶
Parallel applies a function to each input value from a channel using a worker pool of a specified size.
Types ¶
Source Files
Click to show internal directories.
Click to hide internal directories.