async

Documentation

Index

• func Errable(fn func() error) <-chan error
• func FlatMap[T any, D any](src []T, concurrencyLimit int, f func(T) ([]D, error)) ([]D, error)
• func Map[T any, D any](src []T, concurrencyLimit int, f func(T) (D, error)) ([]D, error)
• func WaitAll(chans ...<-chan error) error
• type Errors
  • func (e Errors) Error() any

Functions

func Errable

func Errable(fn func() error) <-chan error

func FlatMap

func FlatMap[T any, D any](src []T, concurrencyLimit int, f func(T) ([]D, error)) ([]D, error)

func Map

func Map[T any, D any](src []T, concurrencyLimit int, f func(T) (D, error)) ([]D, error)

func WaitAll

func WaitAll(chans ...<-chan error) error

WaitAll waits for all the given errables to finish, and returns the last error occurred in all errables, if any.

Types

type Errors

type Errors struct {
	Errs []error
}

func (Errors) Error

func (e Errors) Error() any