lib/redstream/trimmer.rb in redstream-0.6.0 vs lib/redstream/trimmer.rb in redstream-0.6.1

@@ -75,10 +75,10 @@
 
           @logger.debug "Trimmed #{messages.size} messages from #{@stream_name}"
         end
       end
 
-      sleep(5) unless got_lock
+      @lock.wait(5) unless got_lock
     rescue StandardError => e
       @logger.error e
 
       sleep 5