Contents

$LOAD_PATH.unshift File.expand_path("../../lib", __dir__)

require 'async'
require 'async/io/stream'
require 'async/http/url_endpoint'
require 'http/protocol/http2/client'
require 'pry'

queries = ["apple", "orange", "teapot", "async"]

Async.run do
	endpoint = Async::HTTP::URLEndpoint.parse("https://www.google.com")
	
	peer = endpoint.connect
	stream = Async::IO::Stream.new(peer)
	framer = HTTP::Protocol::HTTP2::Framer.new(stream)
	client = HTTP::Protocol::HTTP2::Client.new(framer)
	
	puts "Sending connection preface..."
	client.send_connection_preface
	
	puts "Creating stream..."
	streams = queries.collect do |keyword|
		client.create_stream.tap do |stream|
			headers = [
				[":scheme", endpoint.scheme],
				[":method", "GET"],
				[":authority", "www.google.com"],
				[":path", "/search?q=#{keyword}"],
				["accept", "*/*"],
			]
			
			puts "Sending request on stream id=#{stream.id} state=#{stream.state}..."
			stream.send_headers(nil, headers, HTTP::Protocol::HTTP2::END_STREAM)
		
			def stream.process_headers(frame)
				headers = super
				puts "Stream #{self.id}: Got response headers: #{headers} (#{frame.end_stream?})"
			end
			
			def stream.receive_data(frame)
				data = super
				puts "Stream #{self.id}: Got response data: #{data.bytesize}"
			end
		end
	end
	
	until streams.all?{|stream| stream.closed?}
		frame = client.read_frame
	end
	
	puts "Closing client..."
	client.close
end

puts "Exiting."

Version data entries

11 entries across 11 versions & 1 rubygems

Version	Path
http-protocol-0.17.1	examples/http2/requests.rb
http-protocol-0.17.0	examples/http2/requests.rb
http-protocol-0.16.0	examples/http2/requests.rb
http-protocol-0.15.0	examples/http2/requests.rb
http-protocol-0.14.0	examples/http2/requests.rb
http-protocol-0.13.0	examples/http2/requests.rb
http-protocol-0.12.2	examples/http2/requests.rb
http-protocol-0.12.1	examples/http2/requests.rb
http-protocol-0.12.0	examples/http2/requests.rb
http-protocol-0.11.0	examples/http2/requests.rb
http-protocol-0.10.1	examples/http2/requests.rb