mirror of
https://github.com/c9s/bbgo.git
synced 2024-11-27 01:05:15 +00:00
74 lines
1.4 KiB
Go
74 lines
1.4 KiB
Go
package indicator
|
|
|
|
import (
|
|
"github.com/c9s/bbgo/pkg/types"
|
|
)
|
|
|
|
type KLineSubscription interface {
|
|
AddSubscriber(f func(k types.KLine))
|
|
Length() int
|
|
Last(i int) *types.KLine
|
|
}
|
|
|
|
type PriceStream struct {
|
|
*Float64Series
|
|
|
|
mapper KLineValueMapper
|
|
}
|
|
|
|
func Price(source KLineSubscription, mapper KLineValueMapper) *PriceStream {
|
|
s := &PriceStream{
|
|
Float64Series: NewFloat64Series(),
|
|
mapper: mapper,
|
|
}
|
|
|
|
if source == nil {
|
|
return s
|
|
}
|
|
|
|
source.AddSubscriber(func(k types.KLine) {
|
|
v := s.mapper(k)
|
|
s.PushAndEmit(v)
|
|
})
|
|
return s
|
|
}
|
|
|
|
// AddSubscriber adds the subscriber function and push historical data to the subscriber
|
|
func (s *PriceStream) AddSubscriber(f func(v float64)) {
|
|
s.OnUpdate(f)
|
|
|
|
if len(s.slice) == 0 {
|
|
return
|
|
}
|
|
|
|
// push historical value to the subscriber
|
|
for _, v := range s.slice {
|
|
f(v)
|
|
}
|
|
}
|
|
|
|
func (s *PriceStream) PushAndEmit(v float64) {
|
|
s.slice.Push(v)
|
|
s.EmitUpdate(v)
|
|
}
|
|
|
|
func ClosePrices(source KLineSubscription) *PriceStream {
|
|
return Price(source, KLineClosePriceMapper)
|
|
}
|
|
|
|
func LowPrices(source KLineSubscription) *PriceStream {
|
|
return Price(source, KLineLowPriceMapper)
|
|
}
|
|
|
|
func HighPrices(source KLineSubscription) *PriceStream {
|
|
return Price(source, KLineHighPriceMapper)
|
|
}
|
|
|
|
func OpenPrices(source KLineSubscription) *PriceStream {
|
|
return Price(source, KLineOpenPriceMapper)
|
|
}
|
|
|
|
func Volumes(source KLineSubscription) *PriceStream {
|
|
return Price(source, KLineVolumeMapper)
|
|
}
|