Sha256: a8eceaf882ff3714816fa291ab2d0035cfcb19477ab8c6d7f7bdc6a1c1a0e23d

Contents?: true

Size: 900 Bytes

Versions: 6

Compression:

Stored size: 900 Bytes

Contents

#!/usr/bin/env ruby
# frozen_string_literal: true

require_relative '../../lib/async'

require 'async/http/endpoint'
require 'async/http/server'

require 'async/http/internet'

# To query the web server:
# curl http://localhost:9292/kittens

Async do |parent|
	endpoint = Async::HTTP::Endpoint.parse("http://localhost:9292")
	internet = Async::HTTP::Internet.new
	
	server = Async::HTTP::Server.for(endpoint) do |request|
		if request.path =~ /\/(.*)/
			keyword = $1
			
			response = internet.get("https://www.google.com/search?q=#{keyword}")
			
			count = response.read.scan(keyword).size
			
			Protocol::HTTP::Response[200, [], ["Google found #{count} instance(s) of #{keyword}.\n"]]
		else
			Protocol::HTTP::Response[404, [], []]
		end
	end
	
	tasks = server.run
	
	#while true
	parent.sleep(10)
	parent.reactor.print_hierarchy
	#end
	
	parent.stop # -> Async::Stop
	
	tasks.each(&:stop)
end

Version data entries

6 entries across 6 versions & 1 rubygems

Version Path
async-1.26.1 examples/stop/sleep.rb
async-1.26.0 examples/stop/sleep.rb
async-1.25.2 examples/stop/sleep.rb
async-1.25.1 examples/stop/sleep.rb
async-1.25.0 examples/stop/sleep.rb
async-1.24.2 examples/stop/sleep.rb