JKorf
commented
6 years ago Hi, the GetKlinesAsync method will provide you with a snapshot and history of the requested symbol/interval. It won't automatically update these values for you. In order to receive updates you'll need to use the BinanceSocketClient. I've made a small test program for you which will initially retrieve the klines for a symbol and then keep it updated by subscribing to the socket stream:
private static void TrackKlines()
{
List<BinanceKline> lineData;
using (var client = new BinanceClient())
// Retrieve initial data
lineData = client.GetKlines("ETHBTC", KlineInterval.OneMinute).Data.ToList();
var socketClient = new BinanceSocketClient();
// Subscribe to socket updates
socketClient.SubscribeToKlineStream("ETHBTC", KlineInterval.OneMinute, data =>
{
var existingKline = lineData.SingleOrDefault(k => k.OpenTime == data.Data.StartTime);
if (existingKline == null)
{
// Create a new object if we don't have data for this period yet
existingKline = new BinanceKline()
{
CloseTime = data.Data.EndTime,
OpenTime = data.Data.StartTime
};
lineData.Add(existingKline);
Console.WriteLine($"Added new kline: {existingKline.OpenTime}-{existingKline.CloseTime}");
}
// Update the data of the object
existingKline.High = data.Data.High;
existingKline.Low = data.Data.Low;
existingKline.Close = data.Data.Close;
existingKline.Open = data.Data.Open;
existingKline.Trades = data.Data.TradeCount;
existingKline.Volume = data.Data.Volume;
Console.WriteLine($"Kline updated. Last price: {lineData.OrderByDescending(l => l.OpenTime).First().Close}");
});
Console.ReadLine();
}
mynameisibra
BenVlodgi
Been trying to get a working async of the klines, I get it to display the results but not get the new ones in.