removeAsyncIfSupported() — netty Function Reference

Architecture documentation for the removeAsyncIfSupported() function in AbstractChannelPoolMap.java from the netty codebase.

Function java Buffer Telemetry calls 2 called by 1

Entity Profile

Buffer→ Telemetry→ removeAsyncIfSupported() — netty Function Reference

Dependency Diagram

graph TD
  c0c11a10_371e_2cad_4b08_83e1dfa3ce8f["removeAsyncIfSupported()"]
  dcdf1935_bc76_f2a3_9079_ea2dfd85abec["AbstractChannelPoolMap"]
  c0c11a10_371e_2cad_4b08_83e1dfa3ce8f -->|defined in| dcdf1935_bc76_f2a3_9079_ea2dfd85abec
  5d77c1c4_7bff_ebd6_11b7_c38e5d60916e["close()"]
  5d77c1c4_7bff_ebd6_11b7_c38e5d60916e -->|calls| c0c11a10_371e_2cad_4b08_83e1dfa3ce8f
  979f94b2_e67e_490b_3cac_1bceb7ad4cdb["remove()"]
  c0c11a10_371e_2cad_4b08_83e1dfa3ce8f -->|calls| 979f94b2_e67e_490b_3cac_1bceb7ad4cdb
  5cdb479c_dffc_4a55_7dac_6d05b82ff9be["poolCloseAsyncIfSupported()"]
  c0c11a10_371e_2cad_4b08_83e1dfa3ce8f -->|calls| 5cdb479c_dffc_4a55_7dac_6d05b82ff9be
  style c0c11a10_371e_2cad_4b08_83e1dfa3ce8f fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

transport/src/main/java/io/netty/channel/pool/AbstractChannelPoolMap.java lines 78–92

    private Future<Boolean> removeAsyncIfSupported(K key) {
        P pool =  map.remove(checkNotNull(key, "key"));
        if (pool != null) {
            final Promise<Boolean> removePromise = GlobalEventExecutor.INSTANCE.newPromise();
            poolCloseAsyncIfSupported(pool).addListener(future -> {
                if (future.isSuccess()) {
                    removePromise.setSuccess(Boolean.TRUE);
                } else {
                    removePromise.setFailure(future.cause());
                }
            });
            return removePromise;
        }
        return GlobalEventExecutor.INSTANCE.newSucceededFuture(Boolean.FALSE);
    }