# File lib/raindrops/aggregate/pmq.rb, line 150 def aggregate @cached_aggregate ||= begin flush Marshal.load(synchronize(@rd, RDLOCK) do |rd| IO.pread rd.fileno, rd.stat.size, 0 end) end end