lychiyu/bbgo_origin
1
0
Fork 0
mirror of https://github.com/c9s/bbgo.git synced 2024-11-10 09:11:55 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

core: add trade to the trade store when order is not matched

Browse Source
This commit is contained in:
c9s 2023-08-02 00:17:25 +08:00
parent 7adc786c8a
commit 71d86aa483
No known key found for this signature in database
GPG Key ID: 7385E7E464CB0A54
1 changed files with 5 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
pkg/core/tradecollector.go
View File

@ -77,7 +77,7 @@ func (c *TradeCollector) BindStreamForBackground(stream types.Stream) {
func (c *TradeCollector) BindStream(stream types.Stream) { func (c *TradeCollector) BindStream(stream types.Stream) {
stream.OnTradeUpdate(func(trade types.Trade) { stream.OnTradeUpdate(func(trade types.Trade) {
c.ProcessTrade(trade) c.processTrade(trade)
}) })
} }
@ -194,6 +194,9 @@ func (c *TradeCollector) processTrade(trade types.Trade) bool {
} }
if !c.orderStore.Exists(trade.OrderID) { if !c.orderStore.Exists(trade.OrderID) {
// not done yet
// add this trade to the trade store for the later processing
c.tradeStore.Add(trade)
c.mu.Unlock() c.mu.Unlock()
return false return false
} }
@ -241,7 +244,7 @@ func (c *TradeCollector) Run(ctx context.Context) {
c.Process() c.Process()
case trade := <-c.tradeC: case trade := <-c.tradeC:
c.ProcessTrade(trade) c.processTrade(trade)
} }
} }
} }