PendingStream Class — netty Architecture
Architecture documentation for the PendingStream class in StreamBufferingEncoder.java from the netty codebase.
Entity Profile
Dependency Diagram
graph TD 23c47863_fab2_6ae1_4de8_4c970ef6612e["PendingStream"] ac8d53b1_507e_5b73_32c3_3f65876877d4["StreamBufferingEncoder.java"] 23c47863_fab2_6ae1_4de8_4c970ef6612e -->|defined in| ac8d53b1_507e_5b73_32c3_3f65876877d4 4151ebba_bd2b_d221_59c8_c7be1c12906b["PendingStream()"] 23c47863_fab2_6ae1_4de8_4c970ef6612e -->|method| 4151ebba_bd2b_d221_59c8_c7be1c12906b 936fb734_cb24_77d9_f655_c912a572b30c["sendFrames()"] 23c47863_fab2_6ae1_4de8_4c970ef6612e -->|method| 936fb734_cb24_77d9_f655_c912a572b30c 26c22993_f244_60d5_ec2e_4c99e54c35cc["close()"] 23c47863_fab2_6ae1_4de8_4c970ef6612e -->|method| 26c22993_f244_60d5_ec2e_4c99e54c35cc
Relationship Graph
Source Code
codec-http2/src/main/java/io/netty/handler/codec/http2/StreamBufferingEncoder.java lines 310–331
private static final class PendingStream {
final ChannelHandlerContext ctx;
final int streamId;
final Queue<Frame> frames = new ArrayDeque<Frame>(2);
PendingStream(ChannelHandlerContext ctx, int streamId) {
this.ctx = ctx;
this.streamId = streamId;
}
void sendFrames() {
for (Frame frame : frames) {
frame.send(ctx, streamId);
}
}
void close(Throwable t) {
for (Frame frame : frames) {
frame.release(t);
}
}
}
Source
Frequently Asked Questions
What is the PendingStream class?
PendingStream is a class in the netty codebase, defined in codec-http2/src/main/java/io/netty/handler/codec/http2/StreamBufferingEncoder.java.
Where is PendingStream defined?
PendingStream is defined in codec-http2/src/main/java/io/netty/handler/codec/http2/StreamBufferingEncoder.java at line 310.
Analyze Your Own Codebase
Get architecture documentation, dependency graphs, and domain analysis for your codebase in minutes.
Try Supermodel Free