@@ -32,7 +32,6 @@ namespace ExchangeSharp
32
32
{
33
33
public partial class ExchangeBittrexAPI
34
34
{
35
-
36
35
#if HAS_SIGNALR
37
36
38
37
/// <summary>
@@ -78,7 +77,7 @@ public async Task<IWebSocket> SubscribeToExchangeDeltasAsync(Func<string, Task>
78
77
}
79
78
}
80
79
81
- private BittrexWebSocketManager webSocket ;
80
+ private BittrexWebSocketManager webSocket ;
82
81
83
82
public static string ReverseMarketNameForWS ( string WebSocketFeedMarketName )
84
83
{
@@ -96,10 +95,11 @@ protected override async Task<IWebSocket> OnGetTickersWebSocketAsync(Action<IRea
96
95
async Task innerCallback ( string json )
97
96
{
98
97
#region sample json
98
+
99
99
/*
100
100
{
101
101
Nonce : int,
102
- Deltas :
102
+ Deltas :
103
103
[
104
104
{
105
105
MarketName : string,
@@ -119,15 +119,14 @@ async Task innerCallback(string json)
119
119
]
120
120
}
121
121
*/
122
- #endregion
122
+
123
+ #endregion sample json
123
124
124
125
var freshTickers = new Dictionary < string , ExchangeTicker > ( StringComparer . OrdinalIgnoreCase ) ;
125
126
JToken token = JToken . Parse ( json ) ;
126
127
token = token [ "D" ] ;
127
128
foreach ( JToken ticker in token )
128
129
{
129
-
130
-
131
130
string marketName = ReverseMarketNameForWS ( ticker [ "M" ] . ToStringInvariant ( ) ) ;
132
131
if ( filter . Count != 0 && ! filter . Contains ( marketName ) )
133
132
{
@@ -143,6 +142,7 @@ async Task innerCallback(string json)
143
142
var t = new ExchangeTicker
144
143
{
145
144
MarketSymbol = marketName ,
145
+ ApiResponse = ticker ,
146
146
Ask = ask ,
147
147
Bid = bid ,
148
148
Last = last ,
@@ -176,27 +176,28 @@ params string[] marketSymbols
176
176
Task innerCallback ( string json )
177
177
{
178
178
#region sample json
179
+
179
180
/*
180
181
{
181
182
MarketName : string,
182
183
Nonce : int,
183
- Buys:
184
+ Buys:
184
185
[
185
186
{
186
187
Type : int,
187
188
Rate : decimal,
188
189
Quantity : decimal
189
190
}
190
191
],
191
- Sells:
192
+ Sells:
192
193
[
193
194
{
194
195
Type : int,
195
196
Rate : decimal,
196
197
Quantity : decimal
197
198
}
198
199
],
199
- Fills:
200
+ Fills:
200
201
[
201
202
{
202
203
FillId : int,
@@ -208,7 +209,8 @@ Task innerCallback(string json)
208
209
]
209
210
}
210
211
*/
211
- #endregion
212
+
213
+ #endregion sample json
212
214
213
215
var ordersUpdates = JsonConvert . DeserializeObject < BittrexStreamUpdateExchangeState > ( json ) ;
214
216
var book = new ExchangeOrderBook ( ) ;
@@ -229,8 +231,8 @@ Task innerCallback(string json)
229
231
return Task . CompletedTask ;
230
232
}
231
233
232
- return await new BittrexWebSocketManager ( ) . SubscribeToExchangeDeltasAsync ( innerCallback , marketSymbols ) ;
233
- }
234
+ return await new BittrexWebSocketManager ( ) . SubscribeToExchangeDeltasAsync ( innerCallback , marketSymbols ) ;
235
+ }
234
236
235
237
protected override async Task < IWebSocket > OnGetTradesWebSocketAsync ( Func < KeyValuePair < string , ExchangeTrade > , Task > callback , params string [ ] marketSymbols )
236
238
{
@@ -261,19 +263,17 @@ async Task innerCallback(string json)
261
263
262
264
#endif
263
265
264
- protected override void OnDispose ( )
265
- {
266
-
266
+ protected override void OnDispose ( )
267
+ {
267
268
#if HAS_SIGNALR
268
269
269
- if ( webSocket != null )
270
- {
271
- webSocket . Dispose ( ) ;
272
- webSocket = null ;
273
- }
270
+ if ( webSocket != null )
271
+ {
272
+ webSocket . Dispose ( ) ;
273
+ webSocket = null ;
274
+ }
274
275
275
276
#endif
276
-
277
- }
278
- }
277
+ }
278
+ }
279
279
}
0 commit comments