Use port 0 for automatically assigned ports.

Author: ioquatix

lib/async/http/endpoint.rb

@@ -177,6 +177,10 @@ def endpoint
 				@endpoint ||= build_endpoint
 			end
 
+			def endpoint=(endpoint)
+				@endpoint = build_endpoint(endpoint)
+			end
+			
 			def bind(*arguments, &block)
 				endpoint.bind(*arguments, &block)
 			end

spec/async/http/body_spec.rb

@@ -20,7 +20,7 @@
 
 	context 'with echo server' do
 		let(:server) do
-			Async::HTTP::Server.for(server_endpoint, protocol: described_class) do |request|
+			Async::HTTP::Server.for(@bound_endpoint, protocol: described_class) do |request|
 				input = request.body
 				output = Async::HTTP::Body::Writable.new
 
@@ -55,7 +55,7 @@
 		let(:notification) {Async::Notification.new}
 
 		let(:server) do
-			Async::HTTP::Server.for(server_endpoint, protocol: described_class) do |request|
+			Async::HTTP::Server.for(@bound_endpoint, protocol: described_class) do |request|
 				body = Async::HTTP::Body::Writable.new
 
 				Async::Task.current.async do |task|
@@ -103,8 +103,8 @@
 	let(:client_context) {authority.client_context}
 
 	# Shared port for localhost network tests.
-	let(:server_endpoint) {Async::HTTP::Endpoint.parse("https://localhost:9299", ssl_context: server_context, reuse_port: true)}
-	let(:client_endpoint) {Async::HTTP::Endpoint.parse("https://localhost:9299", ssl_context: client_context, reuse_port: true)}
+	let(:server_endpoint) {Async::HTTP::Endpoint.parse("https://localhost:0", ssl_context: server_context, reuse_port: true)}
+	let(:client_endpoint) {Async::HTTP::Endpoint.parse("https://localhost:0", ssl_context: client_context, reuse_port: true)}
 
 	it_should_behave_like Async::HTTP::Body
 end

spec/async/http/protocol/shared_examples.rb

@@ -443,7 +443,7 @@
 	end
 
 	context 'slow server' do
-		let(:endpoint) {Async::HTTP::Endpoint.parse('http://127.0.0.1:9294', reuse_port: true, timeout: 0.1)}
+		let(:endpoint) {Async::HTTP::Endpoint.parse('http://127.0.0.1:0', reuse_port: true, timeout: 0.1)}
 
 		let(:server) do
 			Async::HTTP::Server.for(@bound_endpoint) do |request|

spec/async/http/server_context.rb

@@ -12,7 +12,7 @@
 	include_context Async::RSpec::Reactor
 
 	let(:protocol) {described_class}
-	let(:endpoint) {Async::HTTP::Endpoint.parse('http://127.0.0.1:9294', timeout: 0.8, reuse_port: true, protocol: protocol)}
+	let(:endpoint) {Async::HTTP::Endpoint.parse('http://127.0.0.1:0', timeout: 0.8, reuse_port: true, protocol: protocol)}
 
 	let(:server_endpoint) {endpoint}
 	let(:client_endpoint) {endpoint}
@@ -37,7 +37,16 @@
 			server.run
 		end
 
-		@client = Async::HTTP::Client.new(client_endpoint, protocol: endpoint.protocol, retries: retries)
+		local_address_endpoint = @bound_endpoint.local_address_endpoint
+		
+		if timeout = client_endpoint.timeout
+			local_address_endpoint.each do |endpoint|
+				endpoint.options = {timeout: timeout}
+			end
+		end
+		
+		client_endpoint.endpoint = local_address_endpoint
+		@client = Async::HTTP::Client.new(client_endpoint, protocol: client_endpoint.protocol, retries: retries)
 	end
 
 	after do