Function TestTextDecoderWithBufioReader

expfmt/decode_test.go:553–579

(t *testing.T)

}

func TestTextDecoderWithBufioReader(t *testing.T) {
	example := `
	# TYPE foo gauge
	foo 0
	`

	var decoded bool
	r := bufio.NewReader(strings.NewReader(example))
	dec := NewDecoder(r, FmtText)
	for {
		var mf dto.MetricFamily
		if err := dec.Decode(&mf); err != nil {
			if errors.Is(err, io.EOF) {
				break
			}
			t.Fatalf("Unexpected error: %v", err)
		}
		if mf.GetName() != "foo" {
			t.Errorf("Unexpected metric name: got %v, expected %v", mf.GetName(), "foo")
		}
		if len(mf.Metric) != 1 {
			t.Errorf("Unexpected number of metrics: got %v, expected %v", len(mf.Metric), 1)
		}
		decoded = true
	}
	require.Truef(t, decoded, "Metric foo not decoded")
}