# -*- encoding: binary -*-# :enddoc:# used to wrap a BasicSocket to use with +q+ for all writes# this is compatible with IO.selectclass Rainbows::WriterThreadPool::Client< Struct.new(:to_io,:q)include Rainbows::SocketProxydefwrite(buf)
q << [ to_io, buf ]enddef close
q << [ to_io,:close]enddef closed?falseendend