lib/redstream/consumer.rb in redstream-0.5.0 vs lib/redstream/consumer.rb in redstream-0.6.0

@@ -88,10 +88,10 @@
         return unless offset
 
         commit offset
       end
 
-      sleep(5) unless got_lock
+      @lock.wait(5) unless got_lock
     rescue StandardError => e
       @logger.error e
 
       sleep 5