@@ -1125,7 +1125,7 @@ public void testMcs(TestServiceGrpc.TestServiceStub asyncStub) throws Exception
11251125 streamObserver1 .onNext (request );
11261126 Object responseObj = responseObserver1 .take ();
11271127 StreamingOutputCallResponse callResponse = (StreamingOutputCallResponse ) responseObj ;
1128- String clientSocketAddressInCall1 = callResponse .getClientSocketAddress ();
1128+ String clientSocketAddressInCall1 = callResponse .getPeerSocketAddress ();
11291129 assertThat (clientSocketAddressInCall1 ).isNotEmpty ();
11301130
11311131 StreamingOutputCallResponseObserver responseObserver2 =
@@ -1134,7 +1134,7 @@ public void testMcs(TestServiceGrpc.TestServiceStub asyncStub) throws Exception
11341134 asyncStub .fullDuplexCall (responseObserver2 );
11351135 streamObserver2 .onNext (request );
11361136 callResponse = (StreamingOutputCallResponse ) responseObserver2 .take ();
1137- String clientSocketAddressInCall2 = callResponse .getClientSocketAddress ();
1137+ String clientSocketAddressInCall2 = callResponse .getPeerSocketAddress ();
11381138
11391139 assertThat (clientSocketAddressInCall1 ).isEqualTo (clientSocketAddressInCall2 );
11401140
@@ -1146,7 +1146,7 @@ public void testMcs(TestServiceGrpc.TestServiceStub asyncStub) throws Exception
11461146 asyncStub .fullDuplexCall (responseObserver3 );
11471147 streamObserver3 .onNext (request );
11481148 callResponse = (StreamingOutputCallResponse ) responseObserver3 .take ();
1149- String clientSocketAddressInCall3 = callResponse .getClientSocketAddress ();
1149+ String clientSocketAddressInCall3 = callResponse .getPeerSocketAddress ();
11501150
11511151 // This assertion is currently failing because connection scaling when MCS limit has been
11521152 // reached is not yet implemented in gRPC Java.
0 commit comments