class Aws::Record::BatchRead

def execute!

Returns:
  • (Array) - an array of unordered new items
def execute!
  operation_keys = unprocessed_keys[0..BATCH_GET_ITEM_LIMIT - 1]
  @unprocessed_keys = unprocessed_keys[BATCH_GET_ITEM_LIMIT..] || []
  operations = build_operations(operation_keys)
  result = @client.batch_get_item(request_items: operations)
  new_items = build_items(result.responses)
  items.concat(new_items)
  update_unprocessed_keys(result.unprocessed_keys) unless result.unprocessed_keys.nil?
  new_items
end