in aws-ecr-registrypolicy/src/main/java/software/amazon/ecr/registrypolicy/UpdateHandler.java [27:47]
private ProgressEvent<ResourceModel, CallbackContext> updateResource(
final AmazonWebServicesClientProxy proxy,
final ProxyClient<EcrClient> proxyClient,
final ProgressEvent<ResourceModel, CallbackContext> progressEvent,
final Logger logger) {
return progressEvent.then(progress ->
proxy.initiate("AWS-ECR-RegistryPolicy::Update::first", proxyClient, progress.getResourceModel(),
progress.getCallbackContext())
.translateToServiceRequest(Translator::translateToPutRequest)
.makeServiceCall((awsRequest, client) -> {
PutRegistryPolicyResponse response = proxy.injectCredentialsAndInvokeV2(awsRequest,
proxyClient.client()::putRegistryPolicy);
logger.log(String.format("%s has successfully been updated.", ResourceModel.TYPE_NAME));
return response;
})
.handleError((awsRequest, exception, client, model, context) ->
this.handleError(exception, model,context))
.progress()
);
}