MCPcopy Create free account
hub / github.com/imroc/req / streamByID

Method streamByID

internal/http2/transport.go:2889–2897  ·  view source on GitHub ↗
(id uint32)

Source from the content-addressed store, hash-verified

2887}
2888
2889func (rl *clientConnReadLoop) streamByID(id uint32) *clientStream {
2890 rl.cc.mu.Lock()
2891 defer rl.cc.mu.Unlock()
2892 cs := rl.cc.streams[id]
2893 if cs != nil && !cs.readAborted {
2894 return cs
2895 }
2896 return nil
2897}
2898
2899func (cs *clientStream) copyTrailers() {
2900 for k, vv := range cs.trailer {

Callers 5

runMethod · 0.95
processHeadersMethod · 0.95
processDataMethod · 0.95
processWindowUpdateMethod · 0.95
processResetStreamMethod · 0.95

Calls 2

LockMethod · 0.80
UnlockMethod · 0.80

Tested by

no test coverage detected