fix:reader don't exit in some cases.

zhangenyao · zhangenyao · commit aee626be0f31 · 2024-03-19T11:03:38.000+08:00
diff --git a/stream_batch.go b/stream_batch.go
@@ -299,7 +299,7 @@ func (sbr *streamBatchReader) reachedEndOfTheGeneration(windowEnd gocql.UUID) bo
 
 func (sbr *streamBatchReader) close(processUntil gocql.UUID) {
 	sbr.endTimestamp.Store(processUntil)
-	sbr.interruptCh <- struct{}{}
+	close(sbr.interruptCh)
 }
 
 func (sbr *streamBatchReader) stopNow() {

Original file line number	Diff line number	Diff line change
`@@ -299,7 +299,7 @@ func (sbr *streamBatchReader) reachedEndOfTheGeneration(windowEnd gocql.UUID) bo`
`299`	`299`
`300`	`300`	`func (sbr *streamBatchReader) close(processUntil gocql.UUID) {`
`301`	`301`	`sbr.endTimestamp.Store(processUntil)`
`302`		`- sbr.interruptCh <- struct{}{}`
	`302`	`+ close(sbr.interruptCh)`
`303`	`303`	`}`
`304`	`304`
`305`	`305`	`func (sbr *streamBatchReader) stopNow() {`