Skip to content
Snippets Groups Projects
Commit 3db76b92 authored by Jan Tattermusch's avatar Jan Tattermusch Committed by GitHub
Browse files

Merge pull request #7066 from y-zeng/ios-test

Fix InteropTests.m
parents ca171cea afb62f80
No related branches found
No related tags found
No related merge requests found
...@@ -58,7 +58,7 @@ ...@@ -58,7 +58,7 @@
requestedResponseSize:(NSNumber *)responseSize { requestedResponseSize:(NSNumber *)responseSize {
RMTStreamingOutputCallRequest *request = [self message]; RMTStreamingOutputCallRequest *request = [self message];
RMTResponseParameters *parameters = [RMTResponseParameters message]; RMTResponseParameters *parameters = [RMTResponseParameters message];
parameters.size = (int)responseSize.integerValue; parameters.size = responseSize.intValue;
[request.responseParametersArray addObject:parameters]; [request.responseParametersArray addObject:parameters];
request.payload.body = [NSMutableData dataWithLength:payloadSize.unsignedIntegerValue]; request.payload.body = [NSMutableData dataWithLength:payloadSize.unsignedIntegerValue];
return request; return request;
...@@ -188,7 +188,7 @@ static cronet_engine *cronetEngine = NULL; ...@@ -188,7 +188,7 @@ static cronet_engine *cronetEngine = NULL;
RMTStreamingOutputCallRequest *request = [RMTStreamingOutputCallRequest message]; RMTStreamingOutputCallRequest *request = [RMTStreamingOutputCallRequest message];
for (NSNumber *size in expectedSizes) { for (NSNumber *size in expectedSizes) {
RMTResponseParameters *parameters = [RMTResponseParameters message]; RMTResponseParameters *parameters = [RMTResponseParameters message];
parameters.size = (int)[size integerValue]; parameters.size = [size intValue];
[request.responseParametersArray addObject:parameters]; [request.responseParametersArray addObject:parameters];
} }
...@@ -284,9 +284,10 @@ static cronet_engine *cronetEngine = NULL; ...@@ -284,9 +284,10 @@ static cronet_engine *cronetEngine = NULL;
// A buffered pipe to which we never write any value acts as a writer that just hangs. // A buffered pipe to which we never write any value acts as a writer that just hangs.
GRXBufferedPipe *requestsBuffer = [[GRXBufferedPipe alloc] init]; GRXBufferedPipe *requestsBuffer = [[GRXBufferedPipe alloc] init];
GRPCProtoCall *call = [_service RPCToStreamingInputCallWithRequestsWriter:requestsBuffer GRPCProtoCall *call =
handler:^(RMTStreamingInputCallResponse *response, [_service RPCToStreamingInputCallWithRequestsWriter:requestsBuffer
NSError *error) { handler:^(RMTStreamingInputCallResponse *response,
NSError *error) {
XCTAssertEqual(error.code, GRPC_STATUS_CANCELLED); XCTAssertEqual(error.code, GRPC_STATUS_CANCELLED);
[expectation fulfill]; [expectation fulfill];
}]; }];
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Please register or to comment