From e7b1d96d1310dbdf413061bed49521ef9bf35374 Mon Sep 17 00:00:00 2001 From: Wolfy-J Date: Sun, 28 Jan 2018 18:31:12 +0300 Subject: Context --- pool.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) (limited to 'pool.go') diff --git a/pool.go b/pool.go index 8dac6cf7..c2226420 100644 --- a/pool.go +++ b/pool.go @@ -109,7 +109,7 @@ func (p *Pool) Exec(rqs *Payload) (rsp *Payload, err error) { } // worker want's to be terminated - if rsp.Body == nil && rsp.Head != nil && string(rsp.Head) == StopRequest { + if rsp.Body == nil && rsp.Context != nil && string(rsp.Context) == StopRequest { go p.replaceWorker(w, err) return p.Exec(rqs) } -- cgit v1.2.3