Sha256: 3c2d6eab05069ae0d92d54b521099dcfc4a65d527204f087e3356018ae526d3d

Contents?: true

Size: 585 Bytes

Versions: 7

Compression:

Stored size: 585 Bytes

Contents

# frozen_string_literal: true

require "sidekiq/web/helpers"

module Sidekiq
  module Belt
    module Ent
      module PeriodicSort
        module SidekiqLoopsPeriodicSort
          def each(&block)
            @lids.map { |lid| Sidekiq::Periodic::Loop.new(lid) }.sort_by(&:klass).each(&block)
          end
        end

        def self.use!
          require("sidekiq-ent/periodic")
          require("sidekiq-ent/periodic/static_loop")

          Sidekiq::Periodic::LoopSet.prepend(Sidekiq::Belt::Ent::PeriodicSort::SidekiqLoopsPeriodicSort)
        end
      end
    end
  end
end

Version data entries

7 entries across 7 versions & 1 rubygems

Version Path
sidekiq-belt-2.0.0 lib/sidekiq/belt/ent/periodic_sort.rb
sidekiq-belt-1.0.0 lib/sidekiq/belt/ent/periodic_sort.rb
sidekiq-belt-0.3.7 lib/sidekiq/belt/ent/periodic_sort.rb
sidekiq-belt-0.3.6 lib/sidekiq/belt/ent/periodic_sort.rb
sidekiq-belt-0.3.5 lib/sidekiq/belt/ent/periodic_sort.rb
sidekiq-belt-0.3.4 lib/sidekiq/belt/ent/periodic_sort.rb
sidekiq-belt-0.3.2 lib/sidekiq/belt/ent/periodic_sort.rb