spec/redstream/lock_spec.rb in redstream-0.0.1 vs spec/redstream/lock_spec.rb in redstream-0.1.0

- old
+ new

@@ -1,15 +1,14 @@ - require File.expand_path("../spec_helper", __dir__) RSpec.describe Redstream::Lock do describe "#acquire" do it "gets a lock" do lock_results = Concurrent::Array.new calls = Concurrent::AtomicFixnum.new(0) - threads = Array.new(2) do |i| + threads = Array.new(2) do |_i| Thread.new do lock_results << Redstream::Lock.new(name: "lock").acquire do calls.increment sleep 1 @@ -63,6 +62,5 @@ expect(calls).to eq(2) expect(lock_results).to eq([1, 1]) end end end -