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

package bitget

import ()

func (s *Stream) OnBookEvent(cb func(o BookEvent)) {
	s.bookEventCallbacks = append(s.bookEventCallbacks, cb)
}

func (s *Stream) EmitBookEvent(o BookEvent) {
	for _, cb := range s.bookEventCallbacks {
		cb(o)
	}
}

func (s *Stream) OnMarketTradeEvent(cb func(o MarketTradeEvent)) {
	s.marketTradeEventCallbacks = append(s.marketTradeEventCallbacks, cb)
}

func (s *Stream) EmitMarketTradeEvent(o MarketTradeEvent) {
	for _, cb := range s.marketTradeEventCallbacks {
		cb(o)
	}
}

func (s *Stream) OnKLineEvent(cb func(o KLineEvent)) {
	s.KLineEventCallbacks = append(s.KLineEventCallbacks, cb)
}

func (s *Stream) EmitKLineEvent(o KLineEvent) {
	for _, cb := range s.KLineEventCallbacks {
		cb(o)
	}
}