Contents

# frozen_string_literal: true

module Wayfarer
  GC = Struct.new(:task) do
    def run
      return unless task.counter.decrement <= 0

      task.metadata.job.run_callbacks(:batch)

      task.barrier.reset!
      task.counter.reset!
    end
  end
end

Version data entries

3 entries across 3 versions & 1 rubygems

Version	Path
wayfarer-0.4.6	lib/wayfarer/gc.rb
wayfarer-0.4.5	lib/wayfarer/gc.rb
wayfarer-0.4.4	lib/wayfarer/gc.rb