fixup! Bitfinex: Fix WS trade processing

thrasher-corp · Dec 29, 2024 · 48ebaf7 · 48ebaf7
1 parent d3406a6
commit 48ebaf7
Showing 1 changed file with 3 additions and 3 deletions.
diff --git 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...)
 	}