Class: Async::HTTP::Protocol::HTTP2::Server

Inherits:
Protocol::HTTP2::Server
  • Object
show all
Includes:
Connection
Defined in:
lib/async/http/protocol/http2/server.rb

Overview

An HTTP/2 server connection that receives requests and sends responses.

Instance Attribute Summary collapse

Attributes included from Connection

#count, #promises, #stream

Instance Method Summary collapse

Methods included from Connection

#as_json, #concurrency, #http1?, #http2?, #peer, #read_in_background, #reusable?, #start_connection, #synchronize, #to_json, #to_s, #version, #viable?, #write_frame, #write_frames

Constructor Details

#initialize(stream) ⇒ Server

Initialize the HTTP/2 server with an IO stream.



22
23
24
25
26
27
28
29
30
31
 
# File 'lib/async/http/protocol/http2/server.rb', line 22

def initialize(stream)
	# Used by some generic methods in Connetion:
	@stream = stream
	
	framer = ::Protocol::HTTP2::Framer.new(stream)
	
	super(framer)
	
	@requests = Async::Queue.new
end

Instance Attribute Details

#requests ⇒ Object (readonly)

Returns the value of attribute requests.



33
34
35
 
# File 'lib/async/http/protocol/http2/server.rb', line 33

def requests
  @requests
end

Instance Method Details

#accept_stream(stream_id) ⇒ Object

Accept a new stream from a client.



37
38
39
40
41
 
# File 'lib/async/http/protocol/http2/server.rb', line 37

def accept_stream(stream_id)
	super do
		Request::Stream.create(self, stream_id)
	end
end

#close(error = nil) ⇒ Object

Close the server connection and stop accepting requests.



44
45
46
47
48
 
# File 'lib/async/http/protocol/http2/server.rb', line 44

def close(error = nil)
	@requests.close
	
	super
end

#each(task: Task.current) ⇒ Object

Enumerate incoming requests, yielding each one for processing.



53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
 
# File 'lib/async/http/protocol/http2/server.rb', line 53

def each(task: Task.current)
	task.annotate("Reading #{version} requests for #{self.class}.")
	barrier = Async::Barrier.new(parent: task)
	
	# It's possible the connection has died before we get here...
	@requests.async(parent: barrier) do |task, request|
		task.annotate("Incoming request: #{request.method} #{request.path.inspect}.")
		
		response = nil
		
		task.defer_stop do
			response = yield(request)
		rescue
			# We need to close the stream if the user code blows up while generating a response:
			request.stream.send_reset_stream(::Protocol::HTTP2::INTERNAL_ERROR)
			
			raise
		else
			request.send_response(response)
			# If send response is successful, we clear it so that we don't close it below.
			response = nil
		ensure
			# If some failure occurs and we didn't send the response correctly, ensure that it's closed:
			response&.close
		end
	end
	
	barrier.wait
ensure
	barrier&.stop
end