operationComplete() — netty Function Reference

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

Function java CommonUtil Concurrent

Entity Profile

CommonUtil→ Concurrent→ operationComplete() — netty Function Reference

Dependency Diagram

graph TD
  ae7b5d31_0682_018a_1164_c59d9b70ebe3["operationComplete()"]
  6b255acd_4eb0_e639_6bd9_6e6d0998b4aa["PromiseAggregator"]
  ae7b5d31_0682_018a_1164_c59d9b70ebe3 -->|defined in| 6b255acd_4eb0_e639_6bd9_6e6d0998b4aa
  style ae7b5d31_0682_018a_1164_c59d9b70ebe3 fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

common/src/main/java/io/netty/util/concurrent/PromiseAggregator.java lines 90–110

    @Override
    public synchronized void operationComplete(F future) throws Exception {
        if (pendingPromises == null) {
            aggregatePromise.setSuccess(null);
        } else {
            pendingPromises.remove(future);
            if (!future.isSuccess()) {
                Throwable cause = future.cause();
                aggregatePromise.setFailure(cause);
                if (failPending) {
                    for (Promise<V> pendingFuture : pendingPromises) {
                        pendingFuture.setFailure(cause);
                    }
                }
            } else {
                if (pendingPromises.isEmpty()) {
                    aggregatePromise.setSuccess(null);
                }
            }
        }
    }