(id uint32)
| 492 | } |
| 493 | |
| 494 | func (h2f *Framer) streamByID(id uint32) *clientStream { |
| 495 | if h2f.cc == nil { |
| 496 | return nil |
| 497 | } |
| 498 | h2f.cc.mu.Lock() |
| 499 | defer h2f.cc.mu.Unlock() |
| 500 | cs := h2f.cc.streams[id] |
| 501 | if cs != nil && !cs.readAborted { |
| 502 | return cs |
| 503 | } |
| 504 | return nil |
| 505 | } |
| 506 | |
| 507 | func (h2f *Framer) currentRequest(id uint32) *http.Request { |
| 508 | if cs := h2f.streamByID(id); cs != nil { |
no test coverage detected