class Proclib::OutputCache
Public Instance Methods
<<(message)
click to toggle source
# File lib/proclib/output_cache.rb, line 19 def << message Entry.new(message.process_tag, message.pipe_name, cache) << message.line end
pipe_aggregate(name)
click to toggle source
# File lib/proclib/output_cache.rb, line 23 def pipe_aggregate(name) process_caches.map {|c| c[name] || []}.flatten end
Private Instance Methods
cache()
click to toggle source
Data structure: { process_tag: { stdin: [], stdout: [] } }
# File lib/proclib/output_cache.rb, line 34 def cache @cache ||= Hash.new end
process_caches()
click to toggle source
# File lib/proclib/output_cache.rb, line 29 def process_caches cache.values end