diff options
| author | Silvan Jegen <s.jegen@gmail.com> | 2017-02-15 12:35:20 +0100 |
|---|---|---|
| committer | Silvan Jegen <s.jegen@gmail.com> | 2017-02-15 12:35:20 +0100 |
| commit | de65f7ec41ed0bfc31e0cc7a87bb04a70dc72a07 (patch) | |
| tree | a68a8091cc0e851600bc650b4c565de341e53db5 /input/http/http.go | |
| parent | 07e3d60146de6c5906382e378cdcb3d6a6989cd0 (diff) | |
Propagate Input error
Diffstat (limited to 'input/http/http.go')
| -rw-r--r-- | input/http/http.go | 3 |
1 files changed, 1 insertions, 2 deletions
diff --git a/input/http/http.go b/input/http/http.go index 71a0340..fcac066 100644 --- a/input/http/http.go +++ b/input/http/http.go @@ -42,9 +42,8 @@ func (hi *HTTPInput) httphandler(w http.ResponseWriter, r *http.Request) { all, err := ioutil.ReadAll(r.Body) if err != nil { fmt.Printf("Error when reading HTTP request body: %q\n", err) - return } - hi.retchan <- &work.Work{Data: all} + hi.retchan <- &work.Work{Data: all, Err: err} } func (hi *HTTPInput) Start() chan *work.Work { |