(id uint32)
| 2887 | } |
| 2888 | |
| 2889 | func (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 | |
| 2899 | func (cs *clientStream) copyTrailers() { |
| 2900 | for k, vv := range cs.trailer { |
no test coverage detected