diff --git a/rw_core/utils/request_queue.go b/rw_core/utils/request_queue.go
index 2c95e23..c96a6a0 100644
--- a/rw_core/utils/request_queue.go
+++ b/rw_core/utils/request_queue.go
@@ -88,7 +88,12 @@
 		return ctx.Err()
 
 	case <-waitingOn:
-		// lock is acquired
+		// Previous request has signaled that it is complete.
+		// This request now can proceed as the active
+		// request
+
+		rq.mutex.Lock()
+		defer rq.mutex.Unlock()
 		rq.current = r
 		return nil
 	}