@@ -234,7 +234,7 @@ protected override async Task<IEnumerable<KeyValuePair<string, ExchangeTicker>>>
234234
235235 protected override Task < IWebSocket > OnGetTickersWebSocketAsync ( Action < IReadOnlyCollection < KeyValuePair < string , ExchangeTicker > > > callback , params string [ ] symbols )
236236 {
237- return ConnectWebSocketAsync ( "/stream?streams=!ticker@arr" , async ( _socket , msg ) =>
237+ return ConnectPublicWebSocketAsync ( "/stream?streams=!ticker@arr" , async ( _socket , msg ) =>
238238 {
239239 JToken token = JToken . Parse ( msg . ToStringFromUTF8 ( ) ) ;
240240 List < KeyValuePair < string , ExchangeTicker > > tickerList = new List < KeyValuePair < string , ExchangeTicker > > ( ) ;
@@ -274,7 +274,7 @@ protected override async Task<IWebSocket> OnGetTradesWebSocketAsync(Func<KeyValu
274274 marketSymbols = ( await GetMarketSymbolsAsync ( ) ) . ToArray ( ) ;
275275 }
276276 string url = await GetWebSocketStreamUrlForSymbolsAsync ( "@aggTrade" , marketSymbols ) ;
277- return await ConnectWebSocketAsync ( url , messageCallback : async ( _socket , msg ) =>
277+ return await ConnectPublicWebSocketAsync ( url , messageCallback : async ( _socket , msg ) =>
278278 {
279279 JToken token = JToken . Parse ( msg . ToStringFromUTF8 ( ) ) ;
280280 string name = token [ "stream" ] . ToStringInvariant ( ) ;
@@ -297,7 +297,7 @@ protected override async Task<IWebSocket> OnGetDeltaOrderBookWebSocketAsync(Acti
297297 marketSymbols = ( await GetMarketSymbolsAsync ( ) ) . ToArray ( ) ;
298298 }
299299 string combined = string . Join ( "/" , marketSymbols . Select ( s => this . NormalizeMarketSymbol ( s ) . ToLowerInvariant ( ) + "@depth@100ms" ) ) ;
300- return await ConnectWebSocketAsync ( $ "/stream?streams={ combined } ", ( _socket , msg ) =>
300+ return await ConnectPublicWebSocketAsync ( $ "/stream?streams={ combined } ", ( _socket , msg ) =>
301301 {
302302 string json = msg . ToStringFromUTF8 ( ) ;
303303 var update = JsonConvert . DeserializeObject < MultiDepthStream > ( json ) ;
@@ -1130,7 +1130,7 @@ protected override async Task<IEnumerable<ExchangeTransaction>> OnGetDepositHist
11301130
11311131 protected override async Task < IWebSocket > OnUserDataWebSocketAsync ( Action < object > callback , string listenKey )
11321132 {
1133- return await ConnectWebSocketAsync ( $ "/ws/{ listenKey } ", ( _socket , msg ) =>
1133+ return await ConnectPublicWebSocketAsync ( $ "/ws/{ listenKey } ", ( _socket , msg ) =>
11341134 {
11351135 JToken token = JToken . Parse ( msg . ToStringFromUTF8 ( ) ) ;
11361136 var eventType = token [ "e" ] . ToStringInvariant ( ) ;
0 commit comments