Method race

java/lib/src/main/java/io/github/ccxt/ws/Future.java:70–85

Race multiple futures — returns a new Future that resolves/rejects when the first input future completes. Matches C# Future.race() and JS Promise.race().

(Future... futures)

     * Matches C# Future.race() and JS Promise.race().
     */
    public static Future race(Future... futures) {
        Future result = new Future();
        AtomicBoolean settled = new AtomicBoolean(false);
        for (Future f : futures) {
            f.completableFuture.whenComplete((val, ex) -> {
                if (settled.compareAndSet(false, true)) {
                    if (ex != null) {
                        result.completableFuture.completeExceptionally(ex);
                    } else {
                        result.completableFuture.complete(val);
                    }
                }
            });
        }
        return result;
    }
}