Function ExpectLinesReceivedNoDiff

internal/testutil/lines.go:21–41

(tb testing.TB, wantLines []*logline.LogLine, gotLines <-chan *logline.LogLine)

}

func ExpectLinesReceivedNoDiff(tb testing.TB, wantLines []*logline.LogLine, gotLines <-chan *logline.LogLine) func() {
	tb.Helper()
	var received []*logline.LogLine

	var wg sync.WaitGroup
	wg.Add(1)
	go func() {
		defer wg.Done()
		for line := range gotLines {
			received = append(received, line)
		}
	}()
	return func() {
		tb.Helper()
		wg.Wait()
		if len(received) != len(wantLines) {
			tb.Errorf("unexpected line count, want %d got %d", len(wantLines), len(received))
		}
		ExpectNoDiff(tb, wantLines, received, IgnoreFields(logline.LogLine{}, "Context"))
	}
}