diff --git a/cffu-core/src/main/java/io/foldright/cffu/CffuFactory.java b/cffu-core/src/main/java/io/foldright/cffu/CffuFactory.java
index 0a761511..83ad58c8 100644
--- a/cffu-core/src/main/java/io/foldright/cffu/CffuFactory.java
+++ b/cffu-core/src/main/java/io/foldright/cffu/CffuFactory.java
@@ -266,11 +266,9 @@ public <T> Cffu<T> newIncompleteCffu() {
     @Contract(pure = true)
     public <T> Cffu<T> toCffu(CompletionStage<T> stage) {
         requireNonNull(stage, "stage is null");
-
-        if (CompletableFutureUtils.isMinStageCf(stage)) {
-            return createMin((CompletableFuture<T>) stage);
-        } else if (stage instanceof CompletableFuture) {
-            return create((CompletableFuture<T>) stage);
+        if (stage instanceof CompletableFuture) {
+            final CompletableFuture<T> cf = (CompletableFuture<T>) stage;
+            return CompletableFutureUtils.isMinStageCf(cf) ? createMin(cf) : create(cf);
         } else if (stage instanceof Cffu) {
             return ((Cffu<T>) stage).resetCffuFactory(this);
         }
diff --git a/cffu-core/src/main/java/io/foldright/cffu/CompletableFutureUtils.java b/cffu-core/src/main/java/io/foldright/cffu/CompletableFutureUtils.java
index 08703cb2..6d1db59b 100644
--- a/cffu-core/src/main/java/io/foldright/cffu/CompletableFutureUtils.java
+++ b/cffu-core/src/main/java/io/foldright/cffu/CompletableFutureUtils.java
@@ -256,7 +256,6 @@ public static <T> CompletableFuture<List<T>> mostResultsOfSuccess(
                 .handle((unused, ex) -> arrayList(MGetSuccessNow0(valueIfNotSuccess, cfArray)));
     }
 
-
     /**
      * Multi-Gets(MGet) the results in the <strong>same order</strong> of the given cfs,
      * use the result value if the given stage is completed successfully, else use the given valueIfNotSuccess
@@ -322,8 +321,8 @@ private static <T> void fill(CompletionStage<? extends T>[] css,
      * IGNORE the compile-time type check.
      */
     @SuppressWarnings({"unchecked", "rawtypes"})
-    private static <T> CompletableFuture<T> f_cast(CompletableFuture<?> f) {
-        return (CompletableFuture) f;
+    private static <T> CompletableFuture<T> f_cast(CompletableFuture<?> cf) {
+        return (CompletableFuture) cf;
     }
 
     /**
@@ -393,8 +392,8 @@ private static <T> CompletableFuture<T> toNonMinCfCopy(CompletionStage<? extends
         return isMinStageCf(f) ? f.toCompletableFuture() : copy(f);
     }
 
-    static <T> boolean isMinStageCf(CompletionStage<? extends T> s) {
-        return "java.util.concurrent.CompletableFuture$MinimalStage".equals(s.getClass().getName());
+    static boolean isMinStageCf(CompletableFuture<?> cf) {
+        return "java.util.concurrent.CompletableFuture$MinimalStage".equals(cf.getClass().getName());
     }
 
     ////////////////////////////////////////////////////////////////////////////////
@@ -1480,8 +1479,7 @@ C exceptionallyAsync(C cf, Function<Throwable, ? extends T> fn, Executor executo
      * @return a new CompletableFuture
      * @see #cffuOrTimeout(CompletableFuture, Executor, long, TimeUnit)
      */
-    public static <C extends CompletableFuture<?>> C cffuOrTimeout(
-            C cf, long timeout, TimeUnit unit) {
+    public static <C extends CompletableFuture<?>> C cffuOrTimeout(C cf, long timeout, TimeUnit unit) {
         return cffuOrTimeout(cf, AsyncPoolHolder.ASYNC_POOL, timeout, unit);
     }
 
@@ -1900,8 +1898,7 @@ public static CffuState state(Future<?> cf) {
      * @param supplier a function returning the value to be used to complete given CompletableFuture
      * @return the given CompletableFuture
      */
-    public static <T, C extends CompletableFuture<? super T>>
-    C completeAsync(C cf, Supplier<? extends T> supplier) {
+    public static <T, C extends CompletableFuture<? super T>> C completeAsync(C cf, Supplier<? extends T> supplier) {
         return completeAsync(cf, supplier, AsyncPoolHolder.ASYNC_POOL);
     }