Return errors from Docker client.Events

provider/docker/docker.go

@@ -2,6 +2,7 @@ package docker
 
 import (
 	"context"
+	"io"
 	"math"
 	"net"
 	"net/http"
@@ -237,18 +238,24 @@ func (p *Provider) Provide(configurationChan chan<- types.ConfigMessage, pool *s
 					}
 
 					eventsc, errc := dockerClient.Events(ctx, options)
-					for event := range eventsc {
+					for {
+						select {
+						case event := <-eventsc:
 							if event.Action == "start" ||
 								event.Action == "die" ||
 								strings.HasPrefix(event.Action, "health_status") {
 								startStopHandle(event)
 							}
+						case err := <-errc:
+							if err == io.EOF {
+								log.Debug("Provider event stream closed")
 							}
-					if err := <-errc; err != nil {
+
 							return err
 						}
 					}
 				}
+			}
 			return nil
 		}
 		notify := func(err error, time time.Duration) {