(cs *clientStream, err error)
| 2882 | } |
| 2883 | |
| 2884 | func (rl *clientConnReadLoop) endStreamError(cs *clientStream, err error) { |
| 2885 | cs.readAborted = true |
| 2886 | cs.abortStream(err) |
| 2887 | } |
| 2888 | |
| 2889 | func (rl *clientConnReadLoop) streamByID(id uint32) *clientStream { |
| 2890 | rl.cc.mu.Lock() |
no test coverage detected