operationComplete() — netty Function Reference

Architecture documentation for the operationComplete() function in PromiseNotifier.java from the netty codebase.

Function java CommonUtil Concurrent called by 1

Entity Profile

CommonUtil→ Concurrent→ operationComplete() — netty Function Reference

Dependency Diagram

graph TD
  5afb16f7_3800_4d37_6240_586aedb10447["operationComplete()"]
  aeb78e16_b6f4_3ab4_4d65_5983ace8ae6f["PromiseNotifier"]
  5afb16f7_3800_4d37_6240_586aedb10447 -->|defined in| aeb78e16_b6f4_3ab4_4d65_5983ace8ae6f
  3885fe7c_1e11_c9a0_a965_102028a2c3e9["F()"]
  3885fe7c_1e11_c9a0_a965_102028a2c3e9 -->|calls| 5afb16f7_3800_4d37_6240_586aedb10447
  style 5afb16f7_3800_4d37_6240_586aedb10447 fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

common/src/main/java/io/netty/util/concurrent/PromiseNotifier.java lines 112–130

    @Override
    public void operationComplete(F future) throws Exception {
        InternalLogger internalLogger = logNotifyFailure ? logger : null;
        if (future.isSuccess()) {
            V result = future.get();
            for (Promise<? super V> p: promises) {
                PromiseNotificationUtil.trySuccess(p, result, internalLogger);
            }
        } else if (future.isCancelled()) {
            for (Promise<? super V> p: promises) {
                PromiseNotificationUtil.tryCancel(p, internalLogger);
            }
        } else {
            Throwable cause = future.cause();
            for (Promise<? super V> p: promises) {
                PromiseNotificationUtil.tryFailure(p, cause, internalLogger);
            }
        }
    }