cascadeTo() — netty Function Reference

Architecture documentation for the cascadeTo() function in UnaryPromiseNotifier.java from the netty codebase.

Function java CommonUtil Concurrent called by 1

Entity Profile

CommonUtil→ Concurrent→ cascadeTo() — netty Function Reference

Dependency Diagram

graph TD
  f34e4ab1_0729_13e2_0c0e_d9b472e13f9b["cascadeTo()"]
  ee4619b3_07f7_4a65_cc8a_746ea69e60d9["UnaryPromiseNotifier"]
  f34e4ab1_0729_13e2_0c0e_d9b472e13f9b -->|defined in| ee4619b3_07f7_4a65_cc8a_746ea69e60d9
  37e8df1a_bf48_8c9e_a48d_39a0687ddedd["operationComplete()"]
  37e8df1a_bf48_8c9e_a48d_39a0687ddedd -->|calls| f34e4ab1_0729_13e2_0c0e_d9b472e13f9b
  style f34e4ab1_0729_13e2_0c0e_d9b472e13f9b fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

common/src/main/java/io/netty/util/concurrent/UnaryPromiseNotifier.java lines 40–55

    public static <X> void cascadeTo(Future<X> completedFuture, Promise<? super X> promise) {
        if (completedFuture.isSuccess()) {
            if (!promise.trySuccess(completedFuture.getNow())) {
                logger.warn("Failed to mark a promise as success because it is done already: {}", promise);
            }
        } else if (completedFuture.isCancelled()) {
            if (!promise.cancel(false)) {
                logger.warn("Failed to cancel a promise because it is done already: {}", promise);
            }
        } else {
            if (!promise.tryFailure(completedFuture.cause())) {
                logger.warn("Failed to mark a promise as failure because it's done already: {}", promise,
                            completedFuture.cause());
            }
        }
    }