(ctx context.Context, h header)
| 415 | } |
| 416 | |
| 417 | func (mr *msgReader) reset(ctx context.Context, h header) { |
| 418 | mr.ctx = ctx |
| 419 | mr.flate = h.rsv1 |
| 420 | mr.limitReader.reset(mr.readFunc) |
| 421 | |
| 422 | if mr.flate { |
| 423 | mr.resetFlate() |
| 424 | } |
| 425 | |
| 426 | mr.setFrame(h) |
| 427 | } |
| 428 | |
| 429 | func (mr *msgReader) setFrame(h header) { |
| 430 | mr.fin = h.fin |
no test coverage detected