# File lib/pr_eventmachine.rb, line 643 643: def self.connect host, port 644: sd = Socket.new( Socket::AF_INET, Socket::SOCK_STREAM, 0 ) 645: begin 646: # TODO, this assumes a current Ruby snapshot. 647: # We need to degrade to a nonblocking connect otherwise. 648: sd.connect_nonblock( Socket.pack_sockaddr_in( port, host )) 649: rescue Errno::EINPROGRESS 650: end 651: EvmaTCPClient.new sd 652: end