fix data retriever (#22632)

jiangxinmeng1 · web-flow · commit aa48108d2045 · 2025-10-16T09:46:36.000Z
fix data retriever Approved by: @XuPeng-SH
diff --git a/pkg/iscp/data_retriever.go b/pkg/iscp/data_retriever.go
@@ -126,12 +126,12 @@ func NewDataRetriever(
 }
 
 func (r *DataRetrieverImpl) Next() *ISCPData {
+	var data *ISCPData
 	select {
 	case <-r.ctx.Done():
 		return nil
-	default:
+	case data = <-r.insertDataCh:
 	}
-	data := <-r.insertDataCh
 	return data
 }
 

Original file line number	Diff line number	Diff line change
`@@ -126,12 +126,12 @@ func NewDataRetriever(`
`126`	`126`	`}`
`127`	`127`
`128`	`128`	`func (r DataRetrieverImpl) Next() ISCPData {`
	`129`	`+ var data *ISCPData`
`129`	`130`	`select {`
`130`	`131`	`case <-r.ctx.Done():`
`131`	`132`	`return nil`
`132`		`- default:`
	`133`	`+ case data = <-r.insertDataCh:`
`133`	`134`	`}`
`134`		`- data := <-r.insertDataCh`
`135`	`135`	`return data`
`136`	`136`	`}`
`137`	`137`