fix double close on chan

This commit is contained in:
rasmus 2022-11-07 00:07:25 +02:00
parent 689ecbcca3
commit d08bbf250a

View File

@ -69,7 +69,6 @@ func (s *submitter) shipFile(ctx context.Context, name string, recordLimitBytes
defer close(lineChan)
sendChan := make(chan mLog, SendQueueLimit)
defer close(sendChan)
go s.parseLines(recordLimitBytes, lineChan, sendChan)