// Code generated by "callbackgen -type KLineStream"; DO NOT EDIT.

package indicatorv2

import (
	"github.com/c9s/bbgo/pkg/types"
)

func (s *KLineStream) OnUpdate(cb func(k types.KLine)) {
	s.updateCallbacks = append(s.updateCallbacks, cb)
}

func (s *KLineStream) EmitUpdate(k types.KLine) {
	for _, cb := range s.updateCallbacks {
		cb(k)
	}
}