# 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