Function TestReadArray_TimeAndDuration

msgp/iter_test.go:524–576

(t *testing.T)

}

func TestReadArray_TimeAndDuration(t *testing.T) {
	var buf bytes.Buffer
	w := NewWriter(&buf)

	now := time.Unix(1700000000, 123456789).UTC()
	durs := []time.Duration{0, time.Second, -5 * time.Millisecond}

	// time.Time
	if err := w.WriteArrayHeader(2); err != nil {
		t.Fatalf("WriteArrayHeader: %v", err)
	}
	if err := w.WriteTime(now); err != nil {
		t.Fatalf("WriteTime: %v", err)
	}
	if err := w.WriteTime(now.Add(time.Minute)); err != nil {
		t.Fatalf("WriteTime: %v", err)
	}

	// time.Duration
	if err := w.WriteArrayHeader(uint32(len(durs))); err != nil {
		t.Fatalf("WriteArrayHeader: %v", err)
	}
	for _, d := range durs {
		if err := w.WriteDuration(d); err != nil {
			t.Fatalf("WriteDuration: %v", err)
		}
	}
	if err := w.Flush(); err != nil {
		t.Fatalf("Flush: %v", err)
	}

	r := NewReader(&buf)
	timesGot, err := collectSeq2(ReadArray[time.Time](r, r.ReadTime))
	if err != nil {
		t.Fatalf("times iteration error: %v", err)
	}
	if len(timesGot) != 2 || !timesGot[0].Equal(now) || !timesGot[1].Equal(now.Add(time.Minute)) {
		t.Fatalf("times mismatch: got %v", timesGot)
	}

	dursGot, err := collectSeq2(ReadArray[time.Duration](r, r.ReadDuration))
	if err != nil {
		t.Fatalf("durations iteration error: %v", err)
	}
	if len(dursGot) != len(durs) {
		t.Fatalf("length mismatch: got %d want %d", len(dursGot), len(durs))
	}
	for i := range durs {
		if dursGot[i] != durs[i] {
			t.Fatalf("index %d: got %v want %v", i, dursGot[i], durs[i])
		}
	}
}

func TestReadNumberArrayBytes_Uint16(t *testing.T) {
	var msg []byte