(p []byte)
| 221 | } |
| 222 | |
| 223 | func (mw *msgWriter) write(p []byte) (int, error) { |
| 224 | n, err := mw.c.writeFrame(mw.ctx, false, mw.flate, mw.opcode, p) |
| 225 | if err != nil { |
| 226 | return n, fmt.Errorf("failed to write data frame: %w", err) |
| 227 | } |
| 228 | mw.opcode = opContinuation |
| 229 | return n, nil |
| 230 | } |
| 231 | |
| 232 | // Close flushes the frame to the connection. |
| 233 | func (mw *msgWriter) Close() (err error) { |