diff options
author | Lin Jen-Shin <godfat@godfat.org> | 2018-12-08 08:30:18 +0000 |
---|---|---|
committer | Eric Wong <e@80x24.org> | 2018-12-08 11:24:36 +0000 |
commit | be8c54482770e3a86020cb7ef6cf26bc5c7ebd16 (patch) | |
tree | fd8e366d6c17d7b24b90e45345b2b58570b6bce3 | |
parent | e7cdf455c5544034f5787bfd747e5858c6f27b7a (diff) | |
download | yahns-be8c54482770e3a86020cb7ef6cf26bc5c7ebd16.tar.gz |
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
-rw-r--r-- | lib/yahns/queue_quitter_pipe.rb | 4 |
1 files changed, 4 insertions, 0 deletions
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 |