util

Documentation

Index

• func CloneChanFn[T, E any](fn func(<-chan T) <-chan E, num int, in <-chan T) <-chan E
• func GenChanFn[T any, E any](logic func(in <-chan T, out chan<- E)) func(<-chan T) <-chan E
• func Multiply[T, E, R any](f func(E) R, g func(T) E) func(T) R
• func SortChan[T sorter](in <-chan T) <-chan T

Functions

func CloneChanFn

func CloneChanFn[T, E any](fn func(<-chan T) <-chan E, num int, in <-chan T) <-chan E

cloning stream channel function means that more goroutines will work for it. and finally all stream will be faned in one channel.

func GenChanFn

func GenChanFn[T any, E any](logic func(in <-chan T, out chan<- E)) func(<-chan T) <-chan E

to make a stream channel function.

func Multiply

func Multiply[T, E, R any](f func(E) R, g func(T) E) func(T) R

multiply two functions to one, right function first.

func SortChan

func SortChan[T sorter](in <-chan T) <-chan T