From be8c54482770e3a86020cb7ef6cf26bc5c7ebd16 Mon Sep 17 00:00:00 2001 From: Lin Jen-Shin Date: Sat, 8 Dec 2018 08:30:18 +0000 Subject: Add QueueQuitter#closed? to queue_quitter_pipe.rb Since we rely on this class being an IO-like class, in Yahns::Queue#worker_thread we're using this method. This fixes an actual error on lib/yahns/queue_kqueue.rb:56 --- lib/yahns/queue_quitter_pipe.rb | 4 ++++ 1 file changed, 4 insertions(+) (limited to 'lib') diff --git a/lib/yahns/queue_quitter_pipe.rb b/lib/yahns/queue_quitter_pipe.rb index eabfb00..789eacd 100644 --- a/lib/yahns/queue_quitter_pipe.rb +++ b/lib/yahns/queue_quitter_pipe.rb @@ -22,4 +22,8 @@ class Yahns::QueueQuitter # :nodoc: @reader.close @to_io.close end + + def closed? + @to_io.closed? + end end -- cgit v1.2.3-24-ge0c7