batch_by_limit

in lib/fluent/plugin/kinesis_helper/api.rb [58:72]

• 14 lines of code
• 2 McCabe index (conditional complexity)

      def batch_by_limit(records, max_count, max_size)
        result, buf, size = records.inject([[],[],0]){|(result, buf, size), record|
          record_size = size_of_values(record)
          if buf.size+1 > max_count or size+record_size > max_size
            result << buf
            buf = []
            size = 0
          end
          buf << record
          size += record_size
          [result, buf, size]
        }
        result << buf
      end