lib/rainbows/writer_thread_pool/client.rb

   1 # -*- encoding: binary -*-
   2 # :enddoc:
   3 # used to wrap a BasicSocket to use with +q+ for all writes
   4 # this is compatible with IO.select
   5 class Rainbows::WriterThreadPool::Client < Struct.new(:to_io, :q)
   6   include Rainbows::SocketProxy
   7
   8   def write(buf)
   9     q << [ to_io, buf ]
  10   end
  11
  12   def close
  13     q << [ to_io, :close ]
  14   end
  15
  16   def closed?
  17     false
  18   end
  19 end