@Test public void testGetFailedOperationsDelimitedNone() { Assert.assertEquals(operationConductor.getFailedOperationsDelimited(","), ""); }
public String getFailedOperationsDelimited(String delimiter) { return failedOperations.stream() .map(operationWrapper -> { String operationName = operationWrapper.getOperation() == null ? UNKNOWN_OPERATION_NAME : operationWrapper.getOperation().getName(); String executorIdentifier = operationWrapper.getOperationExecutor() == null ? UNKNOWN_POD_NAME : operationWrapper.getOperationExecutor().getIdenitifier(); return String.format( "%1$s[%2$s]", operationName, executorIdentifier); } ) .collect(Collectors.joining(delimiter)); }
OperationConductor implements OnOperationCompleteListener { public String getFailedOperationsDelimited(String delimiter) { return failedOperations.stream() .map(operationWrapper -> { String operationName = operationWrapper.getOperation() == null ? UNKNOWN_OPERATION_NAME : operationWrapper.getOperation().getName(); String executorIdentifier = operationWrapper.getOperationExecutor() == null ? UNKNOWN_POD_NAME : operationWrapper.getOperationExecutor().getIdenitifier(); return String.format( "%1$s[%2$s]", operationName, executorIdentifier); } ) .collect(Collectors.joining(delimiter)); } }
OperationConductor implements OnOperationCompleteListener { public String getFailedOperationsDelimited(String delimiter) { return failedOperations.stream() .map(operationWrapper -> { String operationName = operationWrapper.getOperation() == null ? UNKNOWN_OPERATION_NAME : operationWrapper.getOperation().getName(); String executorIdentifier = operationWrapper.getOperationExecutor() == null ? UNKNOWN_POD_NAME : operationWrapper.getOperationExecutor().getIdenitifier(); return String.format( "%1$s[%2$s]", operationName, executorIdentifier); } ) .collect(Collectors.joining(delimiter)); } OperationConductor(Collection<Operation> operations, ExecutorContext executorContext,
        List<OperationConductorModifier> completedOperationModifiers);  OperationConductor(Collection<Operation> operations, ExecutorContext executorContext); }
OperationConductor implements OnOperationCompleteListener { public String getFailedOperationsDelimited(String delimiter) { return failedOperations.stream() .map(operationWrapper -> { String operationName = operationWrapper.getOperation() == null ? UNKNOWN_OPERATION_NAME : operationWrapper.getOperation().getName(); String executorIdentifier = operationWrapper.getOperationExecutor() == null ? UNKNOWN_POD_NAME : operationWrapper.getOperationExecutor().getIdenitifier(); return String.format( "%1$s[%2$s]", operationName, executorIdentifier); } ) .collect(Collectors.joining(delimiter)); } OperationConductor(Collection<Operation> operations, ExecutorContext executorContext,
        List<OperationConductorModifier> completedOperationModifiers);  OperationConductor(Collection<Operation> operations, ExecutorContext executorContext); void run(); @Override void onComplete(OperationWrapper operationWrapper); List<OperationWrapper> getRunningOperations(); List<OperationWrapper> getPendingOperations(); List<OperationWrapper> getFailedOperations(); JsonContextUpdater getJsonContextUpdater(); List<DiagnosticEvent> retrieveAllDiagnosticEvents(); boolean hasExecutionFailed(); String getFailedOperationsDelimited(String delimiter); void setCompletedOperationModifiers(List<OperationConductorModifier> completedOperationModifiers); }
OperationConductor implements OnOperationCompleteListener { public String getFailedOperationsDelimited(String delimiter) { return failedOperations.stream() .map(operationWrapper -> { String operationName = operationWrapper.getOperation() == null ? UNKNOWN_OPERATION_NAME : operationWrapper.getOperation().getName(); String executorIdentifier = operationWrapper.getOperationExecutor() == null ? UNKNOWN_POD_NAME : operationWrapper.getOperationExecutor().getIdenitifier(); return String.format( "%1$s[%2$s]", operationName, executorIdentifier); } ) .collect(Collectors.joining(delimiter)); } OperationConductor(Collection<Operation> operations, ExecutorContext executorContext,
        List<OperationConductorModifier> completedOperationModifiers);  OperationConductor(Collection<Operation> operations, ExecutorContext executorContext); void run(); @Override void onComplete(OperationWrapper operationWrapper); List<OperationWrapper> getRunningOperations(); List<OperationWrapper> getPendingOperations(); List<OperationWrapper> getFailedOperations(); JsonContextUpdater getJsonContextUpdater(); List<DiagnosticEvent> retrieveAllDiagnosticEvents(); boolean hasExecutionFailed(); String getFailedOperationsDelimited(String delimiter); void setCompletedOperationModifiers(List<OperationConductorModifier> completedOperationModifiers);  }