# File lib/earthquake/output.rb, line 18 def output(name = nil, &block) if block outputs.delete_if { |o| o[:name] == name } if name outputs << {:name => name, :block => block} else insert do while item = item_queue.shift item["_stream"] = true puts_items(item) end end end end