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