Clear state upon reconnection

jjxtra · jjxtra · commit 6b134bd1060c · 2021-04-23T16:04:31.000-06:00
diff --git a/src/ExchangeSharp/API/Exchanges/Gemini/ExchangeGeminiAPI.cs b/src/ExchangeSharp/API/Exchanges/Gemini/ExchangeGeminiAPI.cs
@@ -467,6 +467,8 @@ static void PublishTicker(ExchangeTicker ticker, string marketSymbol, Concurrent
 				return Task.CompletedTask;
 			}, connectCallback: async (_socket) =>
 			{
+				volumeDict.Clear();
+				tickerDict.Clear();
 				await _socket.SendMessageAsync(new
 				{
 					type = "subscribe",
@@ -638,6 +640,7 @@ protected override async Task<IWebSocket> OnGetDeltaOrderBookWebSocketAsync(Acti
 			}, connectCallback: async (_socket) =>
 			{
 				//{ "type": "subscribe","subscriptions":[{ "name":"l2","symbols":["BTCUSD","ETHUSD","ETHBTC"]}]}
+				books.Clear();
 				await _socket.SendMessageAsync(new
 				{
 					type = "subscribe",

Original file line number	Diff line number	Diff line change
`@@ -467,6 +467,8 @@ static void PublishTicker(ExchangeTicker ticker, string marketSymbol, Concurrent`
`467`	`467`	`return Task.CompletedTask;`
`468`	`468`	`}, connectCallback: async (_socket) =>`
`469`	`469`	`{`
	`470`	`+ volumeDict.Clear();`
	`471`	`+ tickerDict.Clear();`
`470`	`472`	`await _socket.SendMessageAsync(new`
`471`	`473`	`{`
`472`	`474`	`type = "subscribe",`
`@@ -638,6 +640,7 @@ protected override async Task<IWebSocket> OnGetDeltaOrderBookWebSocketAsync(Acti`
`638`	`640`	`}, connectCallback: async (_socket) =>`
`639`	`641`	`{`
`640`	`642`	`//{ "type": "subscribe","subscriptions":[{ "name":"l2","symbols":["BTCUSD","ETHUSD","ETHBTC"]}]}`
	`643`	`+ books.Clear();`
`641`	`644`	`await _socket.SendMessageAsync(new`
`642`	`645`	`{`
`643`	`646`	`type = "subscribe",`