Sha256: 5eb9d712f9ec38f93049ad434bea1033e270695b9cb69b09c09af074d8955097
Contents?: true
Size: 1.23 KB
Versions: 53
Compression:
Stored size: 1.23 KB
Contents
require "bundler/gem_tasks" require "rspec/core/rake_task" RSpec::Core::RakeTask.new(:test) task :default => :test task :server do require 'async/reactor' require 'async/http/server' app = lambda do |env| [200, {}, ["Hello World"]] end server = Async::HTTP::Server.new([ Async::IO::Endpoint.tcp('127.0.0.1', 9294, reuse_port: true) ], app) Async::Reactor.run do server.run end end task :client do require 'async/reactor' require 'async/http/client' client = Async::HTTP::Client.new([ Async::IO::Endpoint.tcp('127.0.0.1', 9294, reuse_port: true) ]) Async::Reactor.run do response = client.get("/") puts response.inspect end end task :wrk do require 'async/reactor' require 'async/http/server' app = lambda do |env| [200, {}, ["Hello World"]] end server = Async::HTTP::Server.new([ Async::IO::Endpoint.tcp('127.0.0.1', 9294, reuse_port: true) ], app) process_count = Etc.nprocessors pids = process_count.times.collect do fork do Async::Reactor.run do server.run end end end url = "http://127.0.0.1:9294/" connections = process_count system("wrk", "-c", connections.to_s, "-d", "2", "-t", connections.to_s, url) pids.each do |pid| Process.kill(:KILL, pid) Process.wait pid end end
Version data entries
53 entries across 53 versions & 3 rubygems