debian-packages/eventcore
1
0
Fork 0
Code Issues Pull requests Projects Releases Wiki Activity

Fix ConsumableQueue.consume with no entries present.

Browse source
This commit is contained in:
Sönke Ludwig 2017-01-23 11:33:45 +01:00
parent 0422ee495c
commit e5078ad399
No known key found for this signature in database
GPG key ID: D95E8DB493EE314C
1 changed files with 1 additions and 0 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

1
source/eventcore/internal/consumablequeue.d
View file

@ -70,6 +70,7 @@ final class ConsumableQueue(T)
*/ */
ConsumedRange consume() ConsumedRange consume()
@safe { @safe {
if (!m_pendingCount) return ConsumedRange(null, 0, 0);
auto first = (m_first + m_consumedCount) % m_storage.length; auto first = (m_first + m_consumedCount) % m_storage.length;
auto count = m_pendingCount; auto count = m_pendingCount;
m_consumedCount += count; m_consumedCount += count;