removeStream() — netty Function Reference

Architecture documentation for the removeStream() function in DefaultHttp2Connection.java from the netty codebase.

Function java Buffer Allocators calls 3 called by 1

Entity Profile

Buffer→ Allocators→ removeStream() — netty Function Reference

Dependency Diagram

graph TD
  8565aa7a_b0f0_3598_d68c_defa38f2426c["removeStream()"]
  05fa194d_d048_a70f_6ef9_91439d2abc10["DefaultHttp2Connection"]
  8565aa7a_b0f0_3598_d68c_defa38f2426c -->|defined in| 05fa194d_d048_a70f_6ef9_91439d2abc10
  8adb0879_5971_ccaa_50b1_d48d2463e4b8["removeFromActiveStreams()"]
  8adb0879_5971_ccaa_50b1_d48d2463e4b8 -->|calls| 8565aa7a_b0f0_3598_d68c_defa38f2426c
  9d7263ab_8421_ff18_0764_884071aa14a0["id()"]
  8565aa7a_b0f0_3598_d68c_defa38f2426c -->|calls| 9d7263ab_8421_ff18_0764_884071aa14a0
  1ca6cdd9_06c4_3202_3b0c_85ca5c06b18c["isStreamMapEmpty()"]
  8565aa7a_b0f0_3598_d68c_defa38f2426c -->|calls| 1ca6cdd9_06c4_3202_3b0c_85ca5c06b18c
  b4f137d1_9d69_9f36_f01a_901a4f278bc9["size()"]
  8565aa7a_b0f0_3598_d68c_defa38f2426c -->|calls| b4f137d1_9d69_9f36_f01a_901a4f278bc9
  style 8565aa7a_b0f0_3598_d68c_defa38f2426c fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

codec-http2/src/main/java/io/netty/handler/codec/http2/DefaultHttp2Connection.java lines 303–325

    void removeStream(DefaultStream stream, Iterator<?> itr) {
        final boolean removed;
        if (itr == null) {
            removed = streamMap.remove(stream.id()) != null;
        } else {
            itr.remove();
            removed = true;
        }

        if (removed) {
            for (int i = 0; i < listeners.size(); i++) {
                try {
                    listeners.get(i).onStreamRemoved(stream);
                } catch (Throwable cause) {
                    logger.error("Caught Throwable from listener onStreamRemoved.", cause);
                }
            }

            if (closePromise != null && isStreamMapEmpty()) {
                closePromise.trySuccess(null);
            }
        }
    }