channels

Documentation

Index

• func FanIn[T any](ctx context.Context, stream ...<-chan T) <-chan T
• func FanInBounded[T any](ctx context.Context, size int, stream ...<-chan T) <-chan T
• func Filter[T any](data <-chan T, predicate func(T) bool, size int) <-chan T
• func FromSeq[T any](s iter.Seq[T]) <-chan T
• func FromSlice[T any](s []T) <-chan T
• func IntSeq(fromInclusive, toExclusive int) iter.Seq[int]
• func Map[T any, TMap any](s <-chan T, fmap func(el T) TMap, size int) <-chan TMap
• func MapFromSlice[T any, TMap any](s []T, fmap func(el T) TMap, size int) <-chan TMap
• func RangeInt(fromInclusive, toExclusive int) []int
• func ToSlice[T any](s <-chan T) []T
• func Uniq[T comparable](s <-chan T, size int) <-chan T
• func UniqBy[T any, TKey comparable](s <-chan T, f func(T) TKey, size int) <-chan T

Functions

func FanIn

func FanIn[T any](ctx context.Context, stream ...<-chan T) <-chan T

func FanInBounded

func FanInBounded[T any](ctx context.Context, size int, stream ...<-chan T) <-chan T

func Filter

func Filter[T any](data <-chan T, predicate func(T) bool, size int) <-chan T

func FromSeq

func FromSeq[T any](s iter.Seq[T]) <-chan T

func FromSlice

func FromSlice[T any](s []T) <-chan T

func IntSeq

func IntSeq(fromInclusive, toExclusive int) iter.Seq[int]

func Map

func Map[T any, TMap any](s <-chan T, fmap func(el T) TMap, size int) <-chan TMap

func MapFromSlice

func MapFromSlice[T any, TMap any](s []T, fmap func(el T) TMap, size int) <-chan TMap

func RangeInt

func RangeInt(fromInclusive, toExclusive int) []int

func ToSlice

func ToSlice[T any](s <-chan T) []T

func Uniq

func Uniq[T comparable](s <-chan T, size int) <-chan T

func UniqBy

func UniqBy[T any, TKey comparable](s <-chan T, f func(T) TKey, size int) <-chan T