class Rack::HttpStreamingResponse

def close_connection
  return if connection_closed
  session.end_request_hacked
  session.finish
  self.connection_closed = true
end