(p []byte)
| 365 | } |
| 366 | |
| 367 | func (w *writer) Write(p []byte) (int, error) { |
| 368 | if w.closed { |
| 369 | return 0, errors.New("cannot write to closed writer") |
| 370 | } |
| 371 | n, err := w.b.Write(p) |
| 372 | if err != nil { |
| 373 | return n, fmt.Errorf("failed to write message: %w", err) |
| 374 | } |
| 375 | return n, nil |
| 376 | } |
| 377 | |
| 378 | func (w *writer) Close() error { |
| 379 | if w.closed { |