(header []byte)
| 139 | } |
| 140 | |
| 141 | func (r *recvBufferReader) ReadMessageHeader(header []byte) (n int, err error) { |
| 142 | if r.err != nil { |
| 143 | return 0, r.err |
| 144 | } |
| 145 | if r.last != nil { |
| 146 | n, r.last = mem.ReadUnsafe(header, r.last) |
| 147 | return n, nil |
| 148 | } |
| 149 | if r.clientStream != nil { |
| 150 | n, r.err = r.readMessageHeaderClient(header) |
| 151 | } else { |
| 152 | n, r.err = r.readMessageHeader(header) |
| 153 | } |
| 154 | return n, r.err |
| 155 | } |
| 156 | |
| 157 | // Read reads the next n bytes from last. If last is drained, it tries to read |
| 158 | // additional data from recv. It blocks if there no additional data available in |
nothing calls this directly
no test coverage detected