CompletionStage: Pourquoi allof ou ANYOF défini dans CompletableFuture

Question

J'ai un cadre qui utilise l'interface CompletionStage et je suis curieux de savoir pourquoi les méthodes d'aide anyOf ou allOf trouvés dans CompletableFuture y sont définis.

On dirait qu'ils devraient fonctionner sur les interfaces plutôt que sur la mise en œuvre?

Je suis assez insatisfait de l'interface CompletionStage jusqu'à présent. Existe-t-il d'autres bibliothèques Java compatibles avec CompletionStage mais une interface de surensemble différente que quelqu'un peut recommander?

Ou peut-être une bibliothèque écrite avec des méthodes auxiliaires supplémentaires pour travailler avec CompletionStage?

Answer 1

Voici ce que je suis venu avec

/** 
* A class with several helper methods for working with {@link CompletionStage} 
*/ 
public class CompletionStages { 


    public static CompletionStage<Object> anyOf(CompletionStage... completionStages) { 
     if (completionStages == null) { 
      throw new IllegalArgumentException("You must pass a non-null argument for completionStages"); 
     } 
     if (completionStages.length == 0) { 
      throw new IllegalArgumentException("You must pass a non-empty argument for completionStages"); 
     } 

     CompletableFuture result = new CompletableFuture(); 
     for(CompletionStage completionStage : completionStages) { 
      completionStage.thenAccept(r -> result.complete(r)); 
     } 
     return result; 
    } 


    public static CompletionStage<Void> allOf(CompletionStage... completionStages) { 
     if (completionStages == null) { 
      throw new IllegalArgumentException("You must pass a non-null argument for completionStages"); 
     } 
     if (completionStages.length == 0) { 
      throw new IllegalArgumentException("You must pass a non-empty argument for completionStages"); 
     } 

     CompletionStage result = CompletableFuture.completedFuture(null); 
     for(int i = 0; i < completionStages.length; i++) { 
      CompletionStage curr = completionStages[i]; 
      result = result.thenAcceptBoth(curr, (o, o2) -> {}); 
     } 
     return result; 
    } 

} 

Answer 2

Si vous voulez, est une méthode fournissant la même anyOf et allOf fonctionnalité pour les objets du type CompletionStage, vous pouvez simplement recourir à toCompletableFuture:

public static CompletionStage<Object> anyOf(CompletionStage<?>... css) { 
    return CompletableFuture.anyOf(Arrays.stream(css) 
     .map(CompletionStage::toCompletableFuture).toArray(CompletableFuture[]::new)); 
} 
public static CompletionStage<Void> allOf(CompletionStage<?>... css) { 
    return CompletableFuture.allOf(Arrays.stream(css) 
     .map(CompletionStage::toCompletableFuture).toArray(CompletableFuture[]::new)); 
}