recvBufferReader implements io.Reader interface to read the data from recvBuffer.
| 129 | // recvBufferReader implements io.Reader interface to read the data from |
| 130 | // recvBuffer. |
| 131 | type recvBufferReader struct { |
| 132 | _ noCopy |
| 133 | clientStream *ClientStream // The client transport stream is closed with a status representing ctx.Err() and nil trailer metadata. |
| 134 | ctx context.Context |
| 135 | ctxDone <-chan struct{} // cache of ctx.Done() (for performance). |
| 136 | recv *recvBuffer |
| 137 | last mem.Buffer // Stores the remaining data in the previous calls. |
| 138 | err error |
| 139 | } |
| 140 | |
| 141 | func (r *recvBufferReader) ReadMessageHeader(header []byte) (n int, err error) { |
| 142 | if r.err != nil { |
nothing calls this directly
no outgoing calls
no test coverage detected