2011-04-16 04:28:47 -04:00
|
|
|
require 'active_support/core_ext/string/output_safety'
|
|
|
|
|
|
|
|
module ActionView
|
2011-04-16 05:42:02 -04:00
|
|
|
class OutputFlow #:nodoc:
|
2011-04-16 04:28:47 -04:00
|
|
|
attr_reader :content
|
|
|
|
|
|
|
|
def initialize
|
|
|
|
@content = Hash.new { |h,k| h[k] = ActiveSupport::SafeBuffer.new }
|
|
|
|
end
|
|
|
|
|
2011-04-16 05:42:02 -04:00
|
|
|
# Called by _layout_for to read stored values.
|
2011-04-16 04:28:47 -04:00
|
|
|
def get(key)
|
|
|
|
@content[key]
|
|
|
|
end
|
|
|
|
|
2011-04-16 05:42:02 -04:00
|
|
|
# Called by each renderer object to set the layout contents.
|
2011-04-16 04:28:47 -04:00
|
|
|
def set(key, value)
|
2011-04-16 05:42:02 -04:00
|
|
|
@content[key] = value
|
2011-04-16 04:28:47 -04:00
|
|
|
end
|
|
|
|
|
2011-04-16 05:42:02 -04:00
|
|
|
# Called by content_for
|
2011-04-16 04:28:47 -04:00
|
|
|
def append(key, value)
|
|
|
|
@content[key] << value
|
|
|
|
end
|
2011-04-16 05:34:07 -04:00
|
|
|
|
2011-04-16 05:42:02 -04:00
|
|
|
# Called by provide
|
2011-04-16 05:34:07 -04:00
|
|
|
def append!(key, value)
|
|
|
|
@content[key] << value
|
|
|
|
end
|
2011-04-16 04:28:47 -04:00
|
|
|
end
|
|
|
|
|
2011-04-16 05:42:02 -04:00
|
|
|
class StreamingFlow < OutputFlow #:nodoc:
|
2011-04-16 05:22:36 -04:00
|
|
|
def initialize(view, fiber)
|
|
|
|
@view = view
|
|
|
|
@parent = nil
|
|
|
|
@child = view.output_buffer
|
2011-05-01 06:16:31 -04:00
|
|
|
@content = view.view_flow.content
|
2011-04-16 04:28:47 -04:00
|
|
|
@fiber = fiber
|
|
|
|
@root = Fiber.current.object_id
|
|
|
|
end
|
|
|
|
|
|
|
|
# Try to get an stored content. If the content
|
|
|
|
# is not available and we are inside the layout
|
|
|
|
# fiber, we set that we are waiting for the given
|
|
|
|
# key and yield.
|
|
|
|
def get(key)
|
|
|
|
return super if @content.key?(key)
|
|
|
|
|
|
|
|
if inside_fiber?
|
2011-04-16 05:22:36 -04:00
|
|
|
view = @view
|
|
|
|
|
2011-04-16 04:28:47 -04:00
|
|
|
begin
|
|
|
|
@waiting_for = key
|
2011-04-16 05:22:36 -04:00
|
|
|
view.output_buffer, @parent = @child, view.output_buffer
|
2011-04-16 04:28:47 -04:00
|
|
|
Fiber.yield
|
|
|
|
ensure
|
|
|
|
@waiting_for = nil
|
2011-04-16 05:22:36 -04:00
|
|
|
view.output_buffer, @child = @parent, view.output_buffer
|
2011-04-16 04:28:47 -04:00
|
|
|
end
|
|
|
|
end
|
|
|
|
|
|
|
|
super
|
|
|
|
end
|
|
|
|
|
2011-04-16 05:42:02 -04:00
|
|
|
# Appends the contents for the given key. This is called
|
2011-04-16 04:28:47 -04:00
|
|
|
# by provides and resumes back to the fiber if it is
|
|
|
|
# the key it is waiting for.
|
2011-04-16 05:34:07 -04:00
|
|
|
def append!(key, value)
|
2011-04-16 04:28:47 -04:00
|
|
|
super
|
|
|
|
@fiber.resume if @waiting_for == key
|
|
|
|
end
|
|
|
|
|
|
|
|
private
|
|
|
|
|
|
|
|
def inside_fiber?
|
|
|
|
Fiber.current.object_id != @root
|
|
|
|
end
|
|
|
|
end
|
|
|
|
end
|