import java.util.List;
import java.util.concurrent.CompletableFuture;
-import java.util.concurrent.Executor;
import java.util.function.BiConsumer;
import lombok.Getter;
import org.onap.policy.common.endpoints.utils.NetLoggerUtil.EventType;
@Override
protected CompletableFuture<OperationOutcome> startOperationAsync(int attempt, OperationOutcome outcome) {
- final Q request = makeRequest(attempt);
+ final var request = makeRequest(attempt);
final List<String> expectedKeyValues = getExpectedKeyValues(attempt, request);
final PipelineControllerFuture<OperationOutcome> controller = new PipelineControllerFuture<>();
- final Executor executor = params.getExecutor();
+ final var executor = params.getExecutor();
// register a listener BEFORE publishing
/**
* Processes a response.
*
- * @param infra communication infrastructure on which the response was received
* @param outcome outcome to be populated
- * @param response raw response to process
+ * @param rawResponse raw response to process
* @param scoResponse response, as a {@link StandardCoderObject}
* @return the outcome, or {@code null} if still waiting for completion
*/