example/rainbows.rb in rest-more-1.0.2 vs example/rainbows.rb in rest-more-2.0.0

@@ -2,25 +2,66 @@
 worker_processes 4 # assuming four CPU cores
 preload_app      true
 
 Rainbows! do
   use :EventMachine, :em_client_class => lambda{
-    RainbowsEventMachineFiberClient
+    RainbowsEventMachineThreadPoolClient
+    # or
+    # RainbowsEventMachineFiberSpawnClient
   }
   worker_connections        100
 
   client_max_body_size      20*1024*1024 # 20 megabytes
   client_header_buffer_size  8*1024      #  8 kilobytes
 end
 
-require 'rest-more'
-::RC::Builder.default_app = ::RC::Auto
+after_fork{ |_, _|
+  EM.threadpool_size = 32
+  class RainbowsEventMachineThreadPoolClient < Rainbows::EventMachine::Client
+    def app_call input
+      set_comm_inactivity_timeout 0
+      @env[RACK_INPUT] = input
+      @env[REMOTE_ADDR] = @_io.kgio_addr
+      @env[ASYNC_CALLBACK] = method(:write_async_response)
+      @env[ASYNC_CLOSE] = EM::DefaultDeferrable.new
+      @deferred = true
+      EM.defer{
+        status, headers, body = catch(:async) {
+          APP.call(@env.merge!(RACK_DEFAULTS))
+        }
+        if nil == status || -1 == status
+          @deferred = true
+        else
+          @deferred = nil
+          ev_write_response(status, headers, body, @hp.next?)
+        end
+      }
+    end
+  end
 
-class RainbowsEventMachineFiberClient < Rainbows::EventMachine::Client
-  def app_call input
-    Fiber.new{ super }.resume
+  class RainbowsEventMachineFiberSpawnClient < Rainbows::EventMachine::Client
+    def app_call input
+      set_comm_inactivity_timeout 0
+      @env[RACK_INPUT] = input
+      @env[REMOTE_ADDR] = @_io.kgio_addr
+      @env[ASYNC_CALLBACK] = method(:write_async_response)
+      @env[ASYNC_CLOSE] = EM::DefaultDeferrable.new
+      f = Fiber.new{
+        status, headers, body = catch(:async) {
+          APP.call(@env.merge!(RACK_DEFAULTS))
+        }
+        if nil == status || -1 == status
+          @deferred = true
+        else
+          @deferred = nil
+          ev_write_response(status, headers, body, @hp.next?)
+        end
+      }
+      f.resume
+      @deferred = true if f.alive?
+    end
   end
-end
+}
 
 EM.error_handler{ |e|
   puts "Error: EM.error_handler: #{e.inspect} #{e.backtrace.inspect}"
 }