iterx

Documentation

Index

• func Fanout[K any, V any](seq iter.Seq2[K, V], fn func(key K, value V))
• func FanoutErr[K any, V any](seq iter.Seq2[K, V], fn func(key K, value V) error) error
• func For[K any, V any](seq iter.Seq2[K, V], fn func(key K, value V))
• func ForErr[K any, V any](seq iter.Seq2[K, V], fn func(key K, value V) error) error

Functions

func Fanout

func Fanout[K any, V any](seq iter.Seq2[K, V], fn func(key K, value V))

Fanout processes a sequence using a worker pool.

func FanoutErr

func FanoutErr[K any, V any](seq iter.Seq2[K, V], fn func(key K, value V) error) error

FanoutErr processes a sequence using a worker pool, returning an aggregate error.

func For

func For[K any, V any](seq iter.Seq2[K, V], fn func(key K, value V))

For processes a sequence with the given function.

func ForErr

func ForErr[K any, V any](seq iter.Seq2[K, V], fn func(key K, value V) error) error

ForErr processes a sequence with the given function.