bbgo_origin/pkg/exchange/bybit/stream_callbacks.go

26 lines
540 B
Go

// Code generated by "callbackgen -type Stream"; DO NOT EDIT.
package bybit
import ()
func (s *Stream) OnBookEvent(cb func(e BookEvent)) {
s.bookEventCallbacks = append(s.bookEventCallbacks, cb)
}
func (s *Stream) EmitBookEvent(e BookEvent) {
for _, cb := range s.bookEventCallbacks {
cb(e)
}
}
func (s *Stream) OnWalletEvent(cb func(e []*WalletEvent)) {
s.walletEventCallbacks = append(s.walletEventCallbacks, cb)
}
func (s *Stream) EmitWalletEvent(e []*WalletEvent) {
for _, cb := range s.walletEventCallbacks {
cb(e)
}
}