(ctx context.Context)
| 258 | } |
| 259 | |
| 260 | func (c *Conn) readFrameHeader(ctx context.Context) (_ header, err error) { |
| 261 | timeoutSet, err := c.prepareRead(ctx) |
| 262 | if err != nil { |
| 263 | return header{}, err |
| 264 | } |
| 265 | defer c.finishRead(ctx, &err, timeoutSet) |
| 266 | |
| 267 | h, err := readFrameHeader(c.br, c.readHeaderBuf[:]) |
| 268 | if err != nil { |
| 269 | return header{}, err |
| 270 | } |
| 271 | |
| 272 | return h, nil |
| 273 | } |
| 274 | |
| 275 | func (c *Conn) readFramePayload(ctx context.Context, p []byte) (_ int, err error) { |
| 276 | timeoutSet, err := c.prepareRead(ctx) |
no test coverage detected