diff --git a/source/eventcore/internal/consumablequeue.d b/source/eventcore/internal/consumablequeue.d
index a806eb9..6187fdf 100644
--- a/source/eventcore/internal/consumablequeue.d
+++ b/source/eventcore/internal/consumablequeue.d
@@ -70,6 +70,7 @@ final class ConsumableQueue(T)
 	*/
 	ConsumedRange consume()
 	@safe {
+		if (!m_pendingCount) return ConsumedRange(null, 0, 0);
 		auto first = (m_first + m_consumedCount) % m_storage.length;
 		auto count = m_pendingCount;
 		m_consumedCount += count;