lychiyu/bbgo_origin
1
0
Fork 0
mirror of https://github.com/c9s/bbgo.git synced 2024-11-13 02:23:51 +00:00
Code Issues Actions 2 Packages Projects Releases Wiki Activity

pkg/exchange: use balance update instead of snapshot event

Browse Source
This commit is contained in:
Edwin 2023-09-26 16:07:54 +08:00
parent 70884538bc
commit 9f83165032
2 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
pkg/exchange/bybit/stream.go
View File

@ -385,7 +385,7 @@ func (s *Stream) handleMarketTradeEvent(events []MarketTradeEvent) {
} }
func (s *Stream) handleWalletEvent(events []bybitapi.WalletBalances) { func (s *Stream) handleWalletEvent(events []bybitapi.WalletBalances) {
s.StandardStream.EmitBalanceSnapshot(toGlobalBalanceMap(events)) s.StandardStream.EmitBalanceUpdate(toGlobalBalanceMap(events))
} }
func (s *Stream) handleOrderEvent(events []OrderEvent) { func (s *Stream) handleOrderEvent(events []OrderEvent) {

4
pkg/exchange/bybit/stream_test.go
View File

@ -135,8 +135,8 @@ func TestStream(t *testing.T) {
err := s.Connect(context.Background()) err := s.Connect(context.Background())
assert.NoError(t, err) assert.NoError(t, err)
s.OnBalanceSnapshot(func(balances types.BalanceMap) { s.OnBalanceUpdate(func(balances types.BalanceMap) {
t.Log("got snapshot", balances) t.Log("got update", balances)
}) })
c := make(chan struct{}) c := make(chan struct{})
<-c <-c