Sha256: 5486c11bdea1726cfe8959e197a9ae7b9a26d4fd7be02edd6e7484a1fd9e17df
Contents?: true
Size: 844 Bytes
Versions: 85
Compression:
Stored size: 844 Bytes
Contents
module CanvasSync
# An array that "processes" after so many items are added.
#
# Example Usage:
# batches = CanvasSync::BatchProcessor.new(of: 1000) do |batch|
# # Process the batch somehow
# end
# enumerator_of_some_kind.each { |item| batches << item }
# batches.flush
class BatchProcessor
attr_reader :batch_size
def initialize(of: 1000, &blk)
@batch_size = of
@block = blk
@current_batch = []
end
def <<(item)
@current_batch << item
process_batch if @current_batch.count >= batch_size
end
def add_all(items)
items.each do |i|
self << i
end
end
def flush
process_batch if @current_batch.present?
end
protected
def process_batch
@block.call(@current_batch)
@current_batch = []
end
end
end
Version data entries
85 entries across 85 versions & 1 rubygems