refactor: introduce NewXReadResponseAssertion constructor for improved response assertion in testStreamsXreadBlockMaxID

Author: andy1li

internal/resp_assertions/xread_response_assertion.go

@@ -22,6 +22,10 @@ type XReadResponseAssertion struct {
 	ExpectedStreamResponses []StreamResponse
 }
 
+func NewXReadResponseAssertion(expectedValue []StreamResponse) RESPAssertion {
+	return XReadResponseAssertion{ExpectedStreamResponses: expectedValue}
+}
+
 func (a XReadResponseAssertion) Run(value resp_value.Value) error {
 	if value.Type != resp_value.ARRAY {
 		return fmt.Errorf("Expected array, got %s", value.Type)

internal/test_streams_xread_block_max_id.go

@@ -46,15 +46,13 @@ func testStreamsXreadBlockMaxID(stageHarness *test_case_harness.TestCaseHarness)
 	randomInt = testerutils_random.RandomInt(1, 100)
 
 	go func() error {
-		assertion := resp_assertions.XReadResponseAssertion{
-			ExpectedStreamResponses: []resp_assertions.StreamResponse{{
-				Key: randomKey,
-				Entries: []resp_assertions.StreamEntry{{
-					Id:              "0-2",
-					FieldValuePairs: [][]string{{"temperature", strconv.Itoa(randomInt)}},
-				}},
+		assertion := resp_assertions.NewXReadResponseAssertion([]resp_assertions.StreamResponse{{
+			Key: randomKey,
+			Entries: []resp_assertions.StreamEntry{{
+				Id:              "0-2",
+				FieldValuePairs: [][]string{{"temperature", strconv.Itoa(randomInt)}},
 			}},
-		}
+		}})
 		xreadCommandTestCase := &test_cases.SendCommandTestCase{
 			Command:                   "XREAD",
 			Args:                      []string{"block", "0", "streams", randomKey, "$"},