indicator: pull out emit update

c9s · c9s · commit 975d0d69951c · 2022-07-14T11:36:34.000+08:00
diff --git a/pkg/indicator/sma.go b/pkg/indicator/sma.go
@@ -69,14 +69,13 @@ func (inc *SMA) CalculateAndUpdate(allKLines []types.KLine) {
 			if inc.EndTime != zeroTime && k.EndTime.Before(inc.EndTime) {
 				continue
 			}
-
 			inc.PushK(k)
-			inc.EmitUpdate(inc.Values.Last())
 		}
 	} else {
 		inc.PushK(last)
-		inc.EmitUpdate(inc.Values.Last())
 	}
+
+	inc.EmitUpdate(inc.Values.Last())
 }
 
 func (inc *SMA) handleKLineWindowUpdate(interval types.Interval, window types.KLineWindow) {

Original file line number	Diff line number	Diff line change
`@@ -69,14 +69,13 @@ func (inc *SMA) CalculateAndUpdate(allKLines []types.KLine) {`
`69`	`69`	`if inc.EndTime != zeroTime && k.EndTime.Before(inc.EndTime) {`
`70`	`70`	`continue`
`71`	`71`	`}`
`72`		`-`
`73`	`72`	`inc.PushK(k)`
`74`		`- inc.EmitUpdate(inc.Values.Last())`
`75`	`73`	`}`
`76`	`74`	`} else {`
`77`	`75`	`inc.PushK(last)`
`78`		`- inc.EmitUpdate(inc.Values.Last())`
`79`	`76`	`}`
	`77`	`+`
	`78`	`+ inc.EmitUpdate(inc.Values.Last())`
`80`	`79`	`}`
`81`	`80`
`82`	`81`	`func (inc *SMA) handleKLineWindowUpdate(interval types.Interval, window types.KLineWindow) {`