closeAsync() — netty Function Reference

Architecture documentation for the closeAsync() function in FixedChannelPool.java from the netty codebase.

Function java Buffer Telemetry calls 2 called by 1

Entity Profile

Buffer→ Telemetry→ closeAsync() — netty Function Reference

Dependency Diagram

graph TD
  82816a6e_9b06_c34a_e9c2_c740b5363f67["closeAsync()"]
  379a0f3e_d35d_8054_6f12_48a2cfebefb5["FixedChannelPool"]
  82816a6e_9b06_c34a_e9c2_c740b5363f67 -->|defined in| 379a0f3e_d35d_8054_6f12_48a2cfebefb5
  9ac1ba40_078b_abc6_6da9_14f7a9e33ed8["close()"]
  9ac1ba40_078b_abc6_6da9_14f7a9e33ed8 -->|calls| 82816a6e_9b06_c34a_e9c2_c740b5363f67
  95e658c7_942f_e6e6_11e0_8027e4c5999a["close0()"]
  82816a6e_9b06_c34a_e9c2_c740b5363f67 -->|calls| 95e658c7_942f_e6e6_11e0_8027e4c5999a
  24f665bf_9852_2540_7b1a_564ff32355be["run()"]
  82816a6e_9b06_c34a_e9c2_c740b5363f67 -->|calls| 24f665bf_9852_2540_7b1a_564ff32355be
  style 82816a6e_9b06_c34a_e9c2_c740b5363f67 fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

transport/src/main/java/io/netty/channel/pool/FixedChannelPool.java lines 459–479

    @Override
    public Future<Void> closeAsync() {
        if (executor.inEventLoop()) {
            return close0();
        } else {
            final Promise<Void> closeComplete = executor.newPromise();
            executor.execute(new Runnable() {
                @Override
                public void run() {
                    close0().addListener((FutureListener<Void>) f -> {
                        if (f.isSuccess()) {
                            closeComplete.setSuccess(null);
                        } else {
                            closeComplete.setFailure(f.cause());
                        }
                    });
                }
            });
            return closeComplete;
        }
    }