mirror of
https://github.com/c9s/bbgo.git
synced 2024-11-10 09:11:55 +00:00
28 lines
560 B
Go
28 lines
560 B
Go
package indicator
|
|
|
|
import (
|
|
"github.com/c9s/bbgo/pkg/datatype/floats"
|
|
)
|
|
|
|
type PivotLowStream struct {
|
|
Float64Series
|
|
rawValues floats.Slice
|
|
window, rightWindow int
|
|
}
|
|
|
|
func PivotLow2(source Float64Source, window, rightWindow int) *PivotLowStream {
|
|
s := &PivotLowStream{
|
|
Float64Series: NewFloat64Series(),
|
|
window: window,
|
|
rightWindow: rightWindow,
|
|
}
|
|
|
|
s.Subscribe(source, func(x float64) {
|
|
s.rawValues.Push(x)
|
|
if low, ok := calculatePivotLow(s.rawValues, s.window, s.rightWindow); ok {
|
|
s.PushAndEmit(low)
|
|
}
|
|
})
|
|
return s
|
|
}
|