1 files changed, 26 insertions, 0 deletions
diff --git a/spec/ruby/library/thread/shared/queue/close.rb b/spec/ruby/library/thread/shared/queue/close.rb
new file mode 100644
index 0000000000..4457f3ae8b
--- /dev/null
+++ b/spec/ruby/library/thread/shared/queue/close.rb
@@ -0,0 +1,26 @@
+describe :queue_close, shared: true do
+  it "closes the queue and returns nil for further #pop" do
+    q = @object.call
+    q << 1
+    q.close
+    q.pop.should == 1
+    q.pop.should == nil
+    q.pop.should == nil
+  end
+
+  it "prevents further #push" do
+    q = @object.call
+    q.close
+    lambda {
+      q << 1
+    }.should raise_error(ClosedQueueError)
+  end
+
+  it "may be called multiple times" do
+    q = @object.call
+    q.close
+    q.closed?.should be_true
+    q.close # no effect
+    q.closed?.should be_true
+  end
+end