diff options
author | Wolfy-J <[email protected]> | 2018-01-28 18:31:12 +0300 |
---|---|---|
committer | Wolfy-J <[email protected]> | 2018-01-28 18:31:12 +0300 |
commit | e7b1d96d1310dbdf413061bed49521ef9bf35374 (patch) | |
tree | 917e88f163abccfe14548a40f7a02b9a359d263a /pool.go | |
parent | 2756e6c92a89fa1fc09466889670811855ee0429 (diff) |
Context
Diffstat (limited to 'pool.go')
-rw-r--r-- | pool.go | 2 |
1 files changed, 1 insertions, 1 deletions
@@ -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) } |