close ch inside of goroutine

hellofresh · Mar 6, 2018 · 1361161 · 1361161
1 parent 0822b78
commit 1361161
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/pkg/reader/generic/sql.go b/pkg/reader/generic/sql.go
@@ -111,8 +111,8 @@ func (s *SqlReader) ReadTable(tableName string, rowChan chan<- database.Row, opt
 	defer cancel()
 
 	errchan := make(chan error)
-	defer close(errchan)
 	go func() {
+		defer close(errchan)
 		rows, err = query.RunWith(s.GetConnection()).QueryContext(ctx)
 		errchan <- err
 	}()