rdv

Mar 22, 2022

Changes in this version

+ func CtxApply(ctx context.Context, f func(context.Context) (T, error)) func() (T, error)

+ func CtxApplyWatch(ctx context.Context, f func(context.Context) (T, error)) func() (T, error)

+ type Rdv struct

+ func Go(f func() (T, error)) Rdv[T]

+ func GoEg(eg *errgroup.Group, f func() (T, error)) Rdv[T]

+ func (rv Rdv[T]) Receive() (T, error)

+ func (rv Rdv[T]) ReceiveWatch(ctx context.Context) (T, error)