class ActionController::Live::Buffer

:nodoc:

def call_on_error

def call_on_error
  @error_callback.call
end

def close

def close
  super
  @buf.push nil
end

def each

def each
  while str = @buf.pop
    yield str
  end
end

def initialize(response)

:nodoc:
def initialize(response)
  @error_callback = nil
  super(response, SizedQueue.new(10))
end

def on_error(&block)

def on_error(&block)
  @error_callback = block
end

def write(string)

def write(string)
  unless @response.committed?
    @response.headers["Cache-Control"] = "no-cache"
    @response.headers.delete "Content-Length"
  end
  super
end