0
@@ -38,6 +38,7 @@
0
     FFI::server_unlisten()
0
   end
0
   
0
+  # This array is created and manipulated in the C extension.
0
   def FFI.waiting_clients
0
     @waiting_clients
0
   end
0
@@ -56,7 +57,6 @@
0
     }
0
     
0
     def process(app)
0
-      #puts "Request: #{client.inspect}\n"
0
       begin
0
         status, headers, body = app.call(env)
0
       rescue
0
0
0
0
0
0
0
0
0
@@ -66,28 +66,28 @@
0
         body = "Internal Server Error\n"
0
       end
0
       
0
-      FFI::client_write_status(self, status.to_i, HTTP_STATUS_CODES[status.to_i])
0
+      status = status.to_i
0
+      FFI::client_write_status(self, status, HTTP_STATUS_CODES[status])
0
       
0
-      if body.respond_to? :length and status != 304
0
+      if headers.respond_to?(:[]=) and body.respond_to?(:length) and status != 304
0
         headers['Connection'] = 'close'
0
-        headers['Content-Length'] = body.length
0
+        headers['Content-Length'] = body.length.to_s
0
       end
0
       
0
-      headers.each { |k, v| write_header(k,v) }
0
-      
0
+      headers.each { |field, value| write_header(field, value) }
0
       write("\r\n")
0
       
0
-      # Not many apps use streaming yet so i'll hold off on that feature
0
-      # until the rest of ebb is more developed.
0
       if body.kind_of?(String)
0
         write(body)
0
-        FFI::client_set_body_written(self, true)
0
-        FFI::client_begin_transmission(self)
0
+        body_written()
0
+        begin_transmission()
0
       else
0
-        FFI::client_begin_transmission(self)
0
+        begin_transmission()
0
         body.each { |p| write(p) }
0
-        FFI::client_set_body_written(self, true)
0
+        body_written()
0
       end
0
+    rescue => e
0
+      puts "Error! #{e.class}  #{e.message}"
0
     ensure
0
       FFI::client_release(self)
0
     end
0
@@ -105,7 +105,17 @@
0
     end
0
     
0
     def write_header(field, value)
0
-      FFI::client_write_header(self, field.to_s, value.to_s)
0
+      value.send(value.is_a?(String) ? :each_line : :each) do |v| 
0
+        FFI::client_write_header(self, field, v.chomp)
0
+      end
0
+    end
0
+    
0
+    def body_written
0
+      FFI::client_set_body_written(self, true)
0
+    end
0
+    
0
+    def begin_transmission
0
+      FFI::client_begin_transmission(self)
0
     end
0
   end
0