Use Redstream::Lock#wait in Redstream::Trimmer (#12)

mrkamel · Sep 21, 2024 · 5c6be7e · 5c6be7e
1 parent 96e7f3b
commit 5c6be7e
Show file tree

Hide file tree

Showing 3 changed files with 5 additions and 2 deletions.
diff --git a/CHANGELOG.md b/CHANGELOG.md
@@ -1,5 +1,8 @@
 # CHANGELOG
 
+## v0.6.1
+* Use Redstream::Lock#wait in Redstream::Trimmer
+
 ## v0.6.0
 * Allow sharding records into multiple streams
 

diff --git a/lib/redstream/trimmer.rb b/lib/redstream/trimmer.rb
@@ -77,7 +77,7 @@ def run_once
         end
       end
 
-      sleep(5) unless got_lock
+      @lock.wait(5) unless got_lock
     rescue StandardError => e
       @logger.error e
 

diff --git a/lib/redstream/version.rb b/lib/redstream/version.rb
@@ -1,3 +1,3 @@
 module Redstream
-  VERSION = "0.6.0"
+  VERSION = "0.6.1"
 end