write() — netty Function Reference

Architecture documentation for the write() function in SpdyClientStreamIdHandler.java from the netty codebase.

Function java Buffer Telemetry calls 1

Entity Profile

Buffer→ Telemetry→ write() — netty Function Reference

Dependency Diagram

graph TD
  72a367ad_5c3e_2958_6080_455fd434927b["write()"]
  4a6eec03_2db7_6bdd_83fa_89fd1fd0f8bb["SpdyClientStreamIdHandler"]
  72a367ad_5c3e_2958_6080_455fd434927b -->|defined in| 4a6eec03_2db7_6bdd_83fa_89fd1fd0f8bb
  fc119d99_7e1b_0c15_07ba_e9e3f849fad8["acceptOutboundMessage()"]
  72a367ad_5c3e_2958_6080_455fd434927b -->|calls| fc119d99_7e1b_0c15_07ba_e9e3f849fad8
  style 72a367ad_5c3e_2958_6080_455fd434927b fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

example/src/main/java/io/netty/example/spdy/client/SpdyClientStreamIdHandler.java lines 36–47

    @Override
    public void write(ChannelHandlerContext ctx, Object msg, ChannelPromise promise) {
        if (acceptOutboundMessage(msg)) {
            HttpMessage httpMsg = (HttpMessage) msg;
            if (!httpMsg.headers().contains(SpdyHttpHeaders.Names.STREAM_ID)) {
                httpMsg.headers().setInt(Names.STREAM_ID, currentStreamId);
                // Client stream IDs are always odd
                currentStreamId += 2;
            }
        }
        ctx.write(msg, promise);
    }