Untitled

require "eventmachine"

class DeferrableBody
  include EventMachine::Deferrable

  def call(body)
    body.each do |chunk|
      @body_callback.call(chunk)
    end
  end

  def each &blk
    @body_callback = blk
  end
end

class AsyncApp
  def call(env)
    body = DeferrableBody.new

    EventMachine::next_tick {
      env['async.callback'].call [200, {'Content-Type' => 'text/plain'}, body]
      body.call ["Hey!\n"]
    }

    EventMachine::add_timer(2) {
      body.call ["Woah, async!\n"]

      EventMachine::add_timer(3) {
        body.call ["Cheers then!"]
        body.succeed
      }
    }

    throw :async # Still works for supporting non-async frameworks...
  end

end

run AsyncApp.new