(t *testing.T)
| 573 | } |
| 574 | |
| 575 | func TestBufioReadBytes(t *testing.T) { |
| 576 | // Test calling bufio.ReadBytes for value longer than read buffer size. |
| 577 | |
| 578 | m := make([]byte, 512) |
| 579 | m[len(m)-1] = '\n' |
| 580 | |
| 581 | var b1, b2 bytes.Buffer |
| 582 | wc := newConn(fakeNetConn{Writer: &b1}, false, len(m)+64, len(m)+64, nil, nil, nil) |
| 583 | rc := newConn(fakeNetConn{Reader: &b1, Writer: &b2}, true, len(m)-64, len(m)-64, nil, nil, nil) |
| 584 | |
| 585 | w, _ := wc.NextWriter(BinaryMessage) |
| 586 | w.Write(m) |
| 587 | w.Close() |
| 588 | |
| 589 | op, r, err := rc.NextReader() |
| 590 | if op != BinaryMessage || err != nil { |
| 591 | t.Fatalf("NextReader() returned %d, %v", op, err) |
| 592 | } |
| 593 | |
| 594 | br := bufio.NewReader(r) |
| 595 | p, err := br.ReadBytes('\n') |
| 596 | if err != nil { |
| 597 | t.Fatalf("ReadBytes() returned %v", err) |
| 598 | } |
| 599 | if len(p) != len(m) { |
| 600 | t.Fatalf("read returned %d bytes, want %d bytes", len(p), len(m)) |
| 601 | } |
| 602 | } |
| 603 | |
| 604 | var closeErrorTests = []struct { |
| 605 | err error |
nothing calls this directly
no test coverage detected