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