(h header)
| 427 | } |
| 428 | |
| 429 | func (mr *msgReader) setFrame(h header) { |
| 430 | mr.fin = h.fin |
| 431 | mr.payloadLength = h.payloadLength |
| 432 | mr.maskKey = h.maskKey |
| 433 | } |
| 434 | |
| 435 | func (mr *msgReader) Read(p []byte) (n int, err error) { |
| 436 | err = mr.c.readMu.lock(mr.ctx) |