Avoid creating separate async stub for MCS test.

kannanjgithub · kannanjgithub · commit ea6a4aa323f9 · 2026-06-25T07:00:23.000Z
diff --git a/interop-testing/src/main/java/io/grpc/testing/integration/TestServiceClient.java b/interop-testing/src/main/java/io/grpc/testing/integration/TestServiceClient.java
@@ -565,7 +565,7 @@ private void runTest(TestCases testCase) throws Exception {
       }
       
       case MAX_CONCURRENT_STREAMS_CONNECTION_SCALING: {
-        tester.testMcs(TestServiceGrpc.newStub(tester.createChannelBuilder().build()));
+        tester.testMcs();
         break;
       }
       default:
@@ -1076,7 +1076,7 @@ Object take() throws InterruptedException {
       }
     }
 
-    public void testMcs(TestServiceGrpc.TestServiceStub asyncStub) throws Exception {
+    public void testMcs() throws Exception {
       final Object lastItem = new Object();
       StreamingOutputCallResponseObserver responseObserver1 =
           new StreamingOutputCallResponseObserver(lastItem);

Original file line number	Diff line number	Diff line change
`@@ -565,7 +565,7 @@ private void runTest(TestCases testCase) throws Exception {`
`565`	`565`	`}`
`566`	`566`
`567`	`567`	`case MAX_CONCURRENT_STREAMS_CONNECTION_SCALING: {`
`568`		`- tester.testMcs(TestServiceGrpc.newStub(tester.createChannelBuilder().build()));`
	`568`	`+ tester.testMcs();`
`569`	`569`	`break;`
`570`	`570`	`}`
`571`	`571`	`default:`
`@@ -1076,7 +1076,7 @@ Object take() throws InterruptedException {`
`1076`	`1076`	`}`
`1077`	`1077`	`}`
`1078`	`1078`
`1079`		`- public void testMcs(TestServiceGrpc.TestServiceStub asyncStub) throws Exception {`
	`1079`	`+ public void testMcs() throws Exception {`
`1080`	`1080`	`final Object lastItem = new Object();`
`1081`	`1081`	`StreamingOutputCallResponseObserver responseObserver1 =`
`1082`	`1082`	`new StreamingOutputCallResponseObserver(lastItem);`