flywithu/CryptoExchange.Net
1
0
Fork 0
mirror of https://github.com/JKorf/CryptoExchange.Net synced 2026-02-16 14:13:46 +00:00
Code Issues Releases Wiki Activity

Updated SymbolOrderBook.WaitUntilFirstUpdateBufferedAsync

Browse Source
This commit is contained in:
JKorf 2026-01-18 17:36:18 +01:00
parent 5942423bfb
commit 21206ffb25
1 changed files with 14 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

20
CryptoExchange.Net/OrderBook/SymbolOrderBook.cs
View File

@ -643,19 +643,20 @@ namespace CryptoExchange.Net.OrderBook
/// <summary> /// <summary>
/// Wait until an update has been buffered /// Wait until an update has been buffered
/// </summary> /// </summary>
/// <param name="timeout">Max wait time</param> /// <param name="minWait">Min wait time</param>
/// <param name="maxWait">Max wait time</param>
/// <param name="ct">Cancellation token</param> /// <param name="ct">Cancellation token</param>
/// <returns></returns> /// <returns></returns>
protected async Task<CallResult<bool>> WaitUntilFirstUpdateBufferedAsync(TimeSpan timeout, CancellationToken ct) protected async Task<CallResult> WaitUntilFirstUpdateBufferedAsync(TimeSpan? minWait, TimeSpan maxWait, CancellationToken ct)
{ {
var startWait = DateTime.UtcNow; var startWait = DateTime.UtcNow;
while (_processBuffer.Count == 0) while (_processBuffer.Count == 0)
{ {
if (ct.IsCancellationRequested) if (ct.IsCancellationRequested)
return new CallResult<bool>(new CancellationRequestedError()); return new CallResult(new CancellationRequestedError());
if (DateTime.UtcNow - startWait > timeout) if (DateTime.UtcNow - startWait > maxWait)
return new CallResult<bool>(new ServerError(new ErrorInfo(ErrorType.OrderBookTimeout, "Timeout while waiting for data"))); return new CallResult(new ServerError(new ErrorInfo(ErrorType.OrderBookTimeout, "Timeout while waiting for data")));
try try
{ {
@ -665,7 +666,14 @@ namespace CryptoExchange.Net.OrderBook
{ } { }
} }
return new CallResult<bool>(true); if (minWait != null)
{
var dif = DateTime.UtcNow - startWait;
if (dif < minWait)
await Task.Delay(minWait.Value - dif).ConfigureAwait(false);
}
return CallResult.SuccessResult;
} }
/// <summary> /// <summary>