diff --git a/connector/collector/docker_logs.go b/connector/collector/docker_logs.go
index 3f1e40f..ae3d4a9 100644
--- a/connector/collector/docker_logs.go
+++ b/connector/collector/docker_logs.go
@@ -62,10 +62,8 @@ func (l *DockerLogs) Stream() chan models.Log {
 	}()
 
 	go func() {
-		select {
-		case <-l.done:
-			cancel()
-		}
+		<-l.done
+		cancel()
 	}()
 
 	log.Infof("log reader started for container: %s", l.id)