Check new flag in unit test

Signed-off-by: Matt Lord <[email protected]>
vitessio · Dec 3, 2024 · 642219a · 642219a
1 parent 887ede8
commit 642219a
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/go/mysql/binlog_event_mysql56_test.go b/go/mysql/binlog_event_mysql56_test.go
@@ -186,9 +186,11 @@ func TestMysql56DecodeTransactionPayload(t *testing.T) {
 			}
 		}
 		if tc.inMemory {
+			require.False(t, tp.StreamingContents)
 			require.Equal(t, memDecodingCnt+1, compressedTrxPayloadsInMem.Get())
 			require.Equal(t, tc.want, eventStrs)
 		} else {
+			require.True(t, tp.StreamingContents)
 			require.Equal(t, streamDecodingCnt+1, compressedTrxPayloadsUsingStream.Get())
 			require.Len(t, eventStrs, len(tc.want))
 			totalSize := 0