1 files changed, 6 insertions, 1 deletions
diff --git a/input/stdin/stdin.go b/input/stdin/stdin.go
index 394b952..4421741 100644
--- a/input/stdin/stdin.go
+++ b/input/stdin/stdin.go
@@ -33,10 +33,15 @@ func (i *StdinInput) Start() chan *work.Work {
 			if err == io.EOF {
 				break
 			}
+
+			w := &work.Work{Data: bs}
+
 			if err != nil {
 				fmt.Printf("Error when reading input from Stdin: %q", err)
+				w.SetError(err)
 			}
-			i.retchan <- &work.Work{Data: bs, Err: err}
+
+			i.retchan <- w
 		}
 		close(i.retchan)
 	}()