Class: Lowkiq::Splitters::Default

Inherits:

Object

Object
Lowkiq::Splitters::Default

Defined in:: lib/lowkiq/splitters/default.rb

Instance Method Summary collapse

#call(shard_handlers) ⇒ Object
#initialize(threads_per_node) ⇒ Default constructor

A new instance of Default.

Constructor Details

#initialize(threads_per_node) ⇒ `Default`

Returns a new instance of Default.



4
5
6

# File 'lib/lowkiq/splitters/default.rb', line 4

def initialize(threads_per_node)
  @threads_per_node = threads_per_node
end

Instance Method Details

#call(shard_handlers) ⇒ `Object`

# File 'lib/lowkiq/splitters/default.rb', line 8

def call(shard_handlers)
  Utils::Array.new(shard_handlers)
    .in_transposed_groups(@threads_per_node)
    .reject(&:empty?)
end