diff --git a/server/streamtiming.cpp b/server/streamtiming.cpp
index 894c279..e42e764 100644
--- a/server/streamtiming.cpp
+++ b/server/streamtiming.cpp
@@ -88,6 +88,9 @@ quint64 StreamTiming::delay(uint portId, uint guid)
 {
     Q_ASSERT(guid <= SignProtocol::kMaxGuid);
 
+    // Process anything pending first
+    processRecords();
+
     QMutexLocker locker(&timingLock_);
 
     if (!timing_.contains(portId))