(n int)
| 189 | } |
| 190 | |
| 191 | func (r *recvBufferReader) read(n int) (buf mem.Buffer, err error) { |
| 192 | select { |
| 193 | case <-r.ctxDone: |
| 194 | return nil, ContextErr(r.ctx.Err()) |
| 195 | case m := <-r.recv.get(): |
| 196 | return r.readAdditional(m, n) |
| 197 | } |
| 198 | } |
| 199 | |
| 200 | func (r *recvBufferReader) readMessageHeaderClient(header []byte) (n int, err error) { |
| 201 | // If the context is canceled, then closes the stream with nil metadata. |
no test coverage detected