Fix lint

nodece · nodece · commit bf85ef60c7ae · 2025-03-13T01:39:07.000+08:00
diff --git a/pulsar/producer_partition.go b/pulsar/producer_partition.go
@@ -559,11 +559,8 @@ func (p *partitionProducer) reconnectToBroker(connectionClosed *connectionClosed
 }
 
 func (p *partitionProducer) listenBatch() {
-	for {
-		select {
-		case <-p.batchFlushTicker.C:
-			p.internalFlushCurrentBatch()
-		}
+	for range p.batchFlushTicker.C {
+		p.internalFlushCurrentBatch()
 	}
 }
 

Original file line number	Diff line number	Diff line change
`@@ -559,11 +559,8 @@ func (p partitionProducer) reconnectToBroker(connectionClosed connectionClosed`
`559`	`559`	`}`
`560`	`560`
`561`	`561`	`func (p *partitionProducer) listenBatch() {`
`562`		`- for {`
`563`		`- select {`
`564`		`- case <-p.batchFlushTicker.C:`
`565`		`- p.internalFlushCurrentBatch()`
`566`		`- }`
	`562`	`+ for range p.batchFlushTicker.C {`
	`563`	`+ p.internalFlushCurrentBatch()`
`567`	`564`	`}`
`568`	`565`	`}`
`569`	`566`