Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
View Source
var ErrorTimeout = errors.New("time out error")
Functions ¶
This section is empty.
Types ¶
type ErrHandler ¶
type ErrHandler func(err any)
type FetchHandler ¶
type IFanOut ¶
type IFanOut[T any] interface { Produce() chan T Compute(chan T) chan T Merge(...chan T) chan T }
type PriorityHandler ¶
type PriorityHandler func() error
type WaitGroupHandler ¶
type WaitGroupHandler func() error
Click to show internal directories.
Click to hide internal directories.