Address comments v1

Signed-off-by: David Kornel <kornys@outlook.com>

Author: kornys

test-frame-common/src/main/java/io/skodjob/testframe/resources/KubeResourceManager.java

@@ -419,26 +419,10 @@ public final <T extends HasMetadata> void deleteResource(boolean async, T... res
             try {
                 if (type == null) {
                     client.getClient().resource(resource).delete();
-                    CompletableFuture<Void> c = CompletableFuture.runAsync(() ->
-                        assertTrue(waitResourceCondition(resource, ResourceCondition.deletion()),
-                            String.format("Timed out deleting %s/%s in %s", resource.getKind(),
-                                resource.getMetadata().getName(), resource.getMetadata().getNamespace())));
-                    if (async) {
-                        waitExecutors.add(c);
-                    } else {
-                        CompletableFuture.allOf(c).join();
-                    }
+                    decideDeleteWaitAsync(waitExecutors, async, resource);
                 } else {
                     type.delete(resource);
-                    CompletableFuture<Void> c = CompletableFuture.runAsync(() ->
-                        assertTrue(waitResourceCondition(resource, ResourceCondition.deletion()),
-                            String.format("Timed out deleting %s/%s in %s", resource.getKind(),
-                                resource.getMetadata().getName(), resource.getMetadata().getNamespace())));
-                    if (async) {
-                        waitExecutors.add(c);
-                    } else {
-                        CompletableFuture.allOf(c).join();
-                    }
+                    decideDeleteWaitAsync(waitExecutors, async, resource);
                 }
             } catch (Exception e) {
                 if (resource.getMetadata().getNamespace() == null) {
@@ -621,4 +605,17 @@ private void writeResourceAsYaml(HasMetadata resource) {
             throw new RuntimeException(e);
         }
     }
+
+    private <T extends HasMetadata> void decideDeleteWaitAsync(List<CompletableFuture<Void>> waitExecutors,
+                                                               boolean async, T resource) {
+        CompletableFuture<Void> c = CompletableFuture.runAsync(() ->
+            assertTrue(waitResourceCondition(resource, ResourceCondition.deletion()),
+                String.format("Timed out deleting %s/%s in %s", resource.getKind(),
+                    resource.getMetadata().getName(), resource.getMetadata().getNamespace())));
+        if (async) {
+            waitExecutors.add(c);
+        } else {
+            CompletableFuture.allOf(c).join();
+        }
+    }
 }