Versions in this module Expand all Collapse all v2 v2.0.2 Jun 9, 2023 Changes in this version + func FanOut(data ttypes.IFanOut[T], number int) []T + func RunSafe(handler func(), errHandler ...ttypes.ErrHandler) + func WaitGroup(number int, handler ttypes.WaitGroupHandler, closeHandler ...ttypes.ErrHandler) error + type Limit struct + func NewLimit(max int) *Limit + func (r *Limit) Get() + func (r *Limit) Put() + type PriorityChan struct + func NewPriorityChan(size int) *PriorityChan[T] + func (p *PriorityChan[T]) Get() T + func (p *PriorityChan[T]) GetWithTimeout(timeout time.Duration) (T, error) + func (p *PriorityChan[T]) HandleSignal(highHandler ttypes.PriorityHandler[T], lowHandler ttypes.PriorityHandler[T]) error + func (p *PriorityChan[T]) Put(event T, t ttypes.PriorityType) + func (p *PriorityChan[T]) PutWithTimeout(event T, t ttypes.PriorityType, timeout time.Duration) error + func (p *PriorityChan[T]) TryGet() T + func (p *PriorityChan[T]) TryPut(event T, t ttypes.PriorityType) error Other modules containing this package github.com/aronlt/toolkit
Go to main page