From de65f7ec41ed0bfc31e0cc7a87bb04a70dc72a07 Mon Sep 17 00:00:00 2001
From: Silvan Jegen <s.jegen@gmail.com>
Date: Wed, 15 Feb 2017 12:35:20 +0100
Subject: Propagate Input error

---
 manager.go | 4 ++++
 1 file changed, 4 insertions(+)

(limited to 'manager.go')

diff --git a/manager.go b/manager.go
index 0eeb51f..d3d38fd 100644
--- a/manager.go
+++ b/manager.go
@@ -21,6 +21,10 @@ func (m *Manager) Run() {
 
 	ic := m.Input.Start()
 	for w := range ic {
+		if w.Err != nil {
+			fmt.Printf("Got an error when getting Work input: %q\n", w.Err)
+			continue
+		}
 		wg.Add(1)
 
 		go func(w *work.Work) {
-- 
cgit v1.2.1-18-gbd029