split_to_batches

in lib/fluent/plugin/kinesis_helper/api.rb [75:90]

• 15 lines of code
• 3 McCabe index (conditional complexity)

          def split_to_batches(records, &block)
            batch = []
            size = 0
            records.each do |record|
              record_size = size_of_values(record)
              if batch.size+1 > @batch_request_max_count or size+record_size > @batch_request_max_size
                yield(batch, size)
                batch = []
                size = 0
              end
              batch << record
              size += record_size
            end
            yield(batch, size) if batch.size > 0
          end