Versions in this module Expand all Collapse all v0 v0.8.3 Feb 14, 2025 v0.8.2 Feb 14, 2025 Changes in this version + func GetAll[T any](ctx context.Context, futures ...Future[T]) ([]T, error) + type Future struct + func SubmitFuture[T any](ctx context.Context, runner GoroutineRunner, fn func() (T, error)) (Future[T], error) + func (f Future[T]) Get(ctx context.Context) (T, error) + type GoroutineRunner interface + Go func(context.Context, func()) error + func NewSynchronousGoroutineRunner() GoroutineRunner + type LimitedGoroutineRunner struct + func NewGoroutineLimiter(limit int64) *LimitedGoroutineRunner + func (l *LimitedGoroutineRunner) Go(ctx context.Context, fn func()) error + type SynchronousGoroutineRunner struct + func (r *SynchronousGoroutineRunner) Go(_ context.Context, fn func()) error
Go to main page