|
|
@ -285,8 +285,8 @@ static cronet_engine *cronetEngine = NULL; |
|
|
|
GRXBufferedPipe *requestsBuffer = [[GRXBufferedPipe alloc] init]; |
|
|
|
GRXBufferedPipe *requestsBuffer = [[GRXBufferedPipe alloc] init]; |
|
|
|
|
|
|
|
|
|
|
|
GRPCProtoCall *call = [_service RPCToStreamingInputCallWithRequestsWriter:requestsBuffer |
|
|
|
GRPCProtoCall *call = [_service RPCToStreamingInputCallWithRequestsWriter:requestsBuffer |
|
|
|
handler:^(RMTStreamingInputCallResponse *response, |
|
|
|
handler:^(RMTStreamingInputCallResponse *response, |
|
|
|
NSError *error) { |
|
|
|
NSError *error) { |
|
|
|
XCTAssertEqual(error.code, GRPC_STATUS_CANCELLED); |
|
|
|
XCTAssertEqual(error.code, GRPC_STATUS_CANCELLED); |
|
|
|
[expectation fulfill]; |
|
|
|
[expectation fulfill]; |
|
|
|
}]; |
|
|
|
}]; |
|
|
|