Simplify watcher test, fix lgtm warinings and errors

1 files changed, 1 insertions, 1 deletions

diff --git a/worker.go b/worker.go
index 3740aee8..4fbf4369 100644
--- a/worker.go
+++ b/worker.go
@@ -250,7 +250,7 @@ func (w *Worker) execPayload(rqs *Payload) (rsp *Payload, err error) {
 	}
 
 	// add streaming support :)
-	if rsp.Body, pr, err = w.rl.Receive(); err != nil {
+	if rsp.Body, _, err = w.rl.Receive(); err != nil {
 		return nil, errors.Wrap(err, "worker error")
 	}