Merge pull request #2 from paviensky/master

support for :async

lib/async_rack_test/resync_app.rb

@@ -16,8 +16,8 @@ def call(env)
       result = nil
       env['async.callback'] = method(:write_async_response)
       EM.run do
-        response = app.call(env)
-        if response[0] == -1
+        response = catch(:async) { app.call(env) }
+        if response.nil? || response[0] == -1
           EM.add_periodic_timer(0.1) do
             unless @async_response.nil?
               result = @async_response

spec/async_rack_test_spec.rb

@@ -101,6 +101,28 @@ def app
         @result.should == [200, {}, []]
       end
 
+      it "should return when the passed in app throws :async", :slow => true do
+        @trigger_async = nil
+        async_app = Proc.new do |env|
+          EM.add_periodic_timer(0.01) do
+            if @trigger_async # This lets us control when the async behavior actually happens.
+              env['async.callback'].call [200, {}, []]
+            end
+          end
+          throw :async
+        end
+        resync_app = AsyncRackTest::ResyncApp.new(async_app)
+
+        @result = nil
+        thread = Thread.new { @result = resync_app.call({}) }
+
+        sleep 1 # Give some time to guarantee the thread has had time to run.
+        @result.should be_nil
+        @trigger_async = true
+        thread.join
+        @result.should == [200, {}, []]
+      end
+
       it "should return instantly when the passed in app is not async", :slow => true do
         @trigger_async = nil
         async_app = Proc.new do |env|