package
Version:
v0.6.0
Opens a new window with list of versions in this module.
Published: Dec 15, 2024
License: BSD-2-Clause
Opens a new window with license information.
Imports: 2
Opens a new window with list of imports.
Imported by: 0
Opens a new window with list of known importers.
Documentation
¶
-
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 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)
func Batch[T any](ch <-chan T, size int) <-chan []T
Batch batch data of channel
func FanIn[T any](streams ...<-chan T) <-chan T
FanIn split channels
func FanOut[T any](ch chan T, size int, ordered bool) []<-chan T
FanOut split data in channel round-robin
func Parallel[IN, OUT any](stream <-chan IN, fn func(IN) OUT, count int) <-chan OUT
Parallel Worker pool
func Pipeline[IN, OUT any](fn func(IN) OUT) func(<-chan IN) <-chan OUT
Pipeline convert channel for function
func Split[IN, OUT1, OUT2 any](in <-chan IN, fn func(IN) (OUT1, OUT2)) (<-chan OUT1, <-chan OUT2)
Source Files
¶
Click to show internal directories.
Click to hide internal directories.
