diff --git a/tunny.go b/tunny.go index 5957983..b616ba6 100644 --- a/tunny.go +++ b/tunny.go @@ -217,8 +217,8 @@ func (p *Pool) ProcessTimed( // ProcessCtx will use the Pool to process a payload and synchronously return // the result. If the context cancels before the job has finished the worker will -// be interrupted and ErrJobTimedOut will be returned. ProcessCtx can be -// called safely by any goroutines. +// be interrupted and the appropriate context error will be returned. +// ProcessCtx can be called safely by any goroutines. func (p *Pool) ProcessCtx(ctx context.Context, payload interface{}) (interface{}, error) { atomic.AddInt64(&p.queuedJobs, 1) defer atomic.AddInt64(&p.queuedJobs, -1)