concurrent

Documentation

Index

• func Errors(ctx context.Context) (<-chan error, func(err error))
• func Wait(wg *sync.WaitGroup) <-chan struct{}

Functions

func Errors

func Errors(ctx context.Context) (<-chan error, func(err error))

Errors returns an error channel and a function to push an error into that channel. The function returns when either the error is received from the channel or ctx is canceled.

func Wait

func Wait(wg *sync.WaitGroup) <-chan struct{}

Wait returns a channel that is closed when the WaitGroup counter is zero.