diff --git a/exchanges/bitfinex/bitfinex_websocket.go b/exchanges/bitfinex/bitfinex_websocket.go index f48514093f9..e7d0978a479 100644 --- a/exchanges/bitfinex/bitfinex_websocket.go +++ b/exchanges/bitfinex/bitfinex_websocket.go @@ -922,11 +922,11 @@ func (b *Bitfinex) handleWSAllTrades(s *subscription.Subscription, respRaw []byt t.Side = order.Sell t.Amount = math.Abs(t.Amount) } - if feedEnabled { - b.Websocket.DataHandler <- &t - } trades[i] = t } + if feedEnabled { + b.Websocket.DataHandler <- trades + } if b.IsSaveTradeDataEnabled() { err = trade.AddTradesToBuffer(b.GetName(), trades...) }