Fixed problems with the per-symbol news streaming handling logic.

alpacahq · Apr 3, 2022 · be67b62 · be67b62
1 parent a9eeaf1
commit be67b62
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/Alpaca.Markets/DataStreamingClientBase.cs b/Alpaca.Markets/DataStreamingClientBase.cs
@@ -397,7 +397,7 @@ private void handleRealtimeNewsUpdate(
         try
         {
             var channel = token["T"]?.ToString() ?? String.Empty;
-            var symbols = token["S"]?.Values<String>() ?? Enumerable.Empty<String>();
+            var symbols = token["symbols"]?.Values<String>() ?? Enumerable.Empty<String>();
 
             foreach (var symbol in symbols.Where(_ => !String.IsNullOrEmpty(_)))
             {
@@ -486,6 +486,7 @@ private ValueTask sendSubscriptionRequestAsync(
             ? SendAsJsonStringAsync(new JsonSubscriptionUpdate
             {
                 Action = action,
+                News = getSymbols(streamsByChannels, NewsChannel),
                 Trades = getSymbols(streamsByChannels, TradesChannel),
                 Quotes = getSymbols(streamsByChannels, QuotesChannel),
                 Statuses = getSymbols(streamsByChannels, StatusesChannel),