lib/ost.rb in ost-0.1.2 vs lib/ost.rb in ost-0.1.4
- old
+ new
@@ -1,9 +1,9 @@
require "nest"
module Ost
- VERSION = "0.1.2"
+ VERSION = "0.1.4"
TIMEOUT = ENV["OST_TIMEOUT"] || 2
class Queue
attr :key
attr :backup
@@ -22,9 +22,11 @@
loop do
break if @stopping
item = @key.brpoplpush(@backup, TIMEOUT)
+
+ next unless item
block.call(item)
@backup.lpop
end