This commit is contained in:
Aliaksandr Valialkin 2024-05-20 23:45:13 +02:00
parent 33d1b02560
commit 952ffe9dd8
No known key found for this signature in database
GPG key ID: 52C003EE2BCDB9EB
2 changed files with 2 additions and 1 deletions

View file

@ -129,6 +129,7 @@ func TestPipeSort(t *testing.T) {
{
{"_msg", `def`},
{"a", `1`},
{"b", ""},
},
})

View file

@ -216,6 +216,7 @@ func expectPipeResults(t *testing.T, pipeStr string, rows, rowsExpected [][]Fiel
brw.writeRow(row)
}
brw.flush()
pp.flush()
ppTest.expectRows(t, rowsExpected)
}
@ -272,7 +273,6 @@ func (brw *testBlockResultWriter) flush() {
for i := range brw.rcs {
brw.rcs[i].resetValues()
}
brw.ppBase.flush()
}
func newTestPipeProcessor() *testPipeProcessor {