@private
# File lib/em/pure_ruby.rb, line 1152 def initialize io super io @outbound_q = [] end
# File lib/em/pure_ruby.rb, line 1183 def get_outbound_data_size @outbound_q.inject(0) {|memo,obj| memo += (obj || "").length} end
select_for_reading?
# File lib/em/pure_ruby.rb, line 1178 def select_for_reading? true end
select_for_writing?
# File lib/em/pure_ruby.rb, line 1166 def select_for_writing? unless @close_scheduled if @outbound_q.empty? @close_scheduled = true if @close_requested false else true end end end
# File lib/em/pure_ruby.rb, line 1158 def send_datagram data, target # TODO, coalesce here perhaps by being smarter about appending to @outbound_q.last? unless @close_scheduled or @close_requested @outbound_q << [data.to_s, target] end end