(t *testing.T)
| 536 | } |
| 537 | |
| 538 | func TestMessageSetReaderEmpty(t *testing.T) { |
| 539 | m := messageSetReader{empty: true} |
| 540 | |
| 541 | noop := func(*bufio.Reader, int, int) (int, error) { |
| 542 | return 0, nil |
| 543 | } |
| 544 | |
| 545 | offset, _, timestamp, headers, err := m.readMessage(0, noop, noop) |
| 546 | if offset != 0 { |
| 547 | t.Errorf("expected offset of 0, get %d", offset) |
| 548 | } |
| 549 | if timestamp != 0 { |
| 550 | t.Errorf("expected timestamp of 0, get %d", timestamp) |
| 551 | } |
| 552 | if headers != nil { |
| 553 | t.Errorf("expected nil headers, got %v", headers) |
| 554 | } |
| 555 | if !errors.Is(err, RequestTimedOut) { |
| 556 | t.Errorf("expected RequestTimedOut, got %v", err) |
| 557 | } |
| 558 | |
| 559 | if m.remaining() != 0 { |
| 560 | t.Errorf("expected 0 remaining, got %d", m.remaining()) |
| 561 | } |
| 562 | |
| 563 | if m.discard() != nil { |
| 564 | t.Errorf("unexpected error from discard(): %v", m.discard()) |
| 565 | } |
| 566 | } |
| 567 | |
| 568 | func TestMessageFixtures(t *testing.T) { |
| 569 | type fixtureMessage struct { |
nothing calls this directly
no test coverage detected