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