(f http2.Frame)
| 1139 | } |
| 1140 | |
| 1141 | func (t *http2Client) getStream(f http2.Frame) *ClientStream { |
| 1142 | t.mu.Lock() |
| 1143 | s := t.activeStreams[f.Header().StreamID] |
| 1144 | t.mu.Unlock() |
| 1145 | return s |
| 1146 | } |
| 1147 | |
| 1148 | // adjustWindow sends out extra window update over the initial window size |
| 1149 | // of stream if the application is requesting data larger in size than |
no test coverage detected