Method: EventMachine::EvmaUNIXServer#eventable_read

Defined in:
lib/em/pure_ruby.rb

#eventable_read ⇒ Object

– accept_nonblock returns an array consisting of the accepted socket and a sockaddr_in which names the peer. Don’t accept more than 10 at a time.



1130
1131
1132
1133
1134
1135
1136
1137
1138
1139
 
# File 'lib/em/pure_ruby.rb', line 1130

def eventable_read
  begin
    10.times {
      descriptor,peername = io.accept_nonblock
      sd = StreamObject.new descriptor
      EventMachine::event_callback uuid, ConnectionAccepted, sd.uuid
    }
  rescue Errno::EWOULDBLOCK, Errno::EAGAIN
  end
end