Versions in this module Expand all Collapse all v2 v2.0.2 Nov 6, 2023 Changes in this version + var ErrChannelClosed = errors.New("channel is closed") + func Await(ctx context.Context, ch <-chan Option[T]) (value T, err error) + func Go(ctx context.Context, f Func[T], capacity ...int) <-chan Option[T] + func Group(ctx context.Context, g func(i int) Func[T], n int, capacity ...int) <-chan Option[T] + func TrySend(ctx context.Context, ch chan<- Option[T], value T) (err error) + func TrySendError(ctx context.Context, ch chan<- Option[T], err error) (_ error) + func With(ctx context.Context, opt ...OptFunc) (context.Context, context.CancelFunc) + type Func func(chan<- Option[T]) error + type OptFunc func(ctx context.Context) context.Context + func Wait() OptFunc + type Option struct + func MakeErr(err error) Option[T] + func MakeValue(v T) Option[T] + func (opt Option[T]) Err() error + func (opt Option[T]) Value() T Other modules containing this package github.com/WinPooh32/async