diff options
author | Wolfy-J <[email protected]> | 2018-06-11 21:38:24 +0300 |
---|---|---|
committer | Wolfy-J <[email protected]> | 2018-06-11 21:38:24 +0300 |
commit | 5b35d066154437d4a26c1bd8b8e3689b72b36acf (patch) | |
tree | 309e441a03c3033a2bb30654d783f5f955dbb617 /worker.go | |
parent | d9c1da5b559fe1d761f3f91b18648c0ff6ab3634 (diff) |
no library dependency
Diffstat (limited to 'worker.go')
-rw-r--r-- | worker.go | 1 |
1 files changed, 1 insertions, 0 deletions
@@ -237,6 +237,7 @@ func (w *Worker) execPayload(rqs *Payload) (rsp *Payload, err error) { return nil, JobError(rsp.Context) } + // add streaming support :) if rsp.Body, pr, err = w.rl.Receive(); err != nil { return nil, errors.Wrap(err, "worker error") } |