mirror of
https://github.com/JKorf/CryptoExchange.Net
synced 2026-02-16 14:13:46 +00:00
Added WaitUntilFirstUpdateBufferedAsync method on SymbolOrderBook, fixed sequencen validation bug SymbolOrderBook
This commit is contained in:
parent
c71a81e686
commit
dc4abc42a7
@ -640,6 +640,34 @@ namespace CryptoExchange.Net.OrderBook
|
|||||||
return new CallResult<bool>(true);
|
return new CallResult<bool>(true);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
/// <summary>
|
||||||
|
/// Wait until an update has been buffered
|
||||||
|
/// </summary>
|
||||||
|
/// <param name="timeout">Max wait time</param>
|
||||||
|
/// <param name="ct">Cancellation token</param>
|
||||||
|
/// <returns></returns>
|
||||||
|
protected async Task<CallResult<bool>> WaitUntilFirstUpdateBufferedAsync(TimeSpan timeout, CancellationToken ct)
|
||||||
|
{
|
||||||
|
var startWait = DateTime.UtcNow;
|
||||||
|
while (_processBuffer.Count == 0)
|
||||||
|
{
|
||||||
|
if (ct.IsCancellationRequested)
|
||||||
|
return new CallResult<bool>(new CancellationRequestedError());
|
||||||
|
|
||||||
|
if (DateTime.UtcNow - startWait > timeout)
|
||||||
|
return new CallResult<bool>(new ServerError(new ErrorInfo(ErrorType.OrderBookTimeout, "Timeout while waiting for data")));
|
||||||
|
|
||||||
|
try
|
||||||
|
{
|
||||||
|
await Task.Delay(20, ct).ConfigureAwait(false);
|
||||||
|
}
|
||||||
|
catch (OperationCanceledException)
|
||||||
|
{ }
|
||||||
|
}
|
||||||
|
|
||||||
|
return new CallResult<bool>(true);
|
||||||
|
}
|
||||||
|
|
||||||
/// <summary>
|
/// <summary>
|
||||||
/// IDisposable implementation for the order book
|
/// IDisposable implementation for the order book
|
||||||
/// </summary>
|
/// </summary>
|
||||||
@ -1002,7 +1030,8 @@ namespace CryptoExchange.Net.OrderBook
|
|||||||
|
|
||||||
private SequenceNumberResult ValidateLiveSequenceNumber(long sequenceNumber)
|
private SequenceNumberResult ValidateLiveSequenceNumber(long sequenceNumber)
|
||||||
{
|
{
|
||||||
if (sequenceNumber < LastSequenceNumber)
|
if (sequenceNumber < LastSequenceNumber
|
||||||
|
&& (_firstUpdateAfterSnapshotDone || !_skipSequenceCheckFirstUpdateAfterSnapshotSet))
|
||||||
// Update is somehow from before the current state
|
// Update is somehow from before the current state
|
||||||
return SequenceNumberResult.OutOfSync;
|
return SequenceNumberResult.OutOfSync;
|
||||||
|
|
||||||
|
|||||||
Loading…
x
Reference in New Issue
Block a user