class Async::IO::SocketEndpoint

def connect(&block)
	if block_given?
		begin
			yield @socket
		ensure
			@socket.reactor = nil
		end
	else
		return @socket
	end
end