finish() — netty Function Reference

Architecture documentation for the finish() function in PromiseCombiner.java from the netty codebase.

Function java CommonUtil Concurrent calls 2

Entity Profile

CommonUtil→ Concurrent→ finish() — netty Function Reference

Dependency Diagram

graph TD
  b848fecf_3695_33cb_cafc_ce4f3330b4f6["finish()"]
  c034bf85_ba3b_f7d0_2aee_bede5bf5f89f["PromiseCombiner"]
  b848fecf_3695_33cb_cafc_ce4f3330b4f6 -->|defined in| c034bf85_ba3b_f7d0_2aee_bede5bf5f89f
  61cc60e0_a4a2_7876_29bb_7633ddc4c93a["checkInEventLoop()"]
  b848fecf_3695_33cb_cafc_ce4f3330b4f6 -->|calls| 61cc60e0_a4a2_7876_29bb_7633ddc4c93a
  00240b50_b7c1_0e8b_e97f_d918cdc518a8["tryPromise()"]
  b848fecf_3695_33cb_cafc_ce4f3330b4f6 -->|calls| 00240b50_b7c1_0e8b_e97f_d918cdc518a8
  style b848fecf_3695_33cb_cafc_ce4f3330b4f6 fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

common/src/main/java/io/netty/util/concurrent/PromiseCombiner.java lines 151–161

    public void finish(Promise<Void> aggregatePromise) {
        ObjectUtil.checkNotNull(aggregatePromise, "aggregatePromise");
        checkInEventLoop();
        if (this.aggregatePromise != null) {
            throw new IllegalStateException("Already finished");
        }
        this.aggregatePromise = aggregatePromise;
        if (doneCount == expectedCount) {
            tryPromise();
        }
    }