Resolving testResponsesOver4MBAreAcceptedIfOptedIn delayed callback

pull/19298/head
Muxi Yan 6 years ago
parent bb6a97b0c8
commit 9601b46ffa
  1. 8
      src/objective-c/tests/InteropTests/InteropTests.m

@ -18,6 +18,8 @@
#import "InteropTests.h" #import "InteropTests.h"
#import <libkern/OSAtomic.h>
#include <grpc/status.h> #include <grpc/status.h>
#ifdef GRPC_COMPILE_WITH_CRONET #ifdef GRPC_COMPILE_WITH_CRONET
@ -701,21 +703,21 @@ initWithInterceptorManager:(GRPCInterceptorManager *)interceptorManager
XCTAssertNotNil([[self class] host]); XCTAssertNotNil([[self class] host]);
__weak XCTestExpectation *expectation = __weak XCTestExpectation *expectation =
[self expectationWithDescription:@"HigherResponseSizeLimit"]; [self expectationWithDescription:@"HigherResponseSizeLimit"];
__block NSError *callError = nil;
RMTSimpleRequest *request = [RMTSimpleRequest message]; RMTSimpleRequest *request = [RMTSimpleRequest message];
const size_t kPayloadSize = 5 * 1024 * 1024; // 5MB const size_t kPayloadSize = 5 * 1024 * 1024; // 5MB
request.responseSize = kPayloadSize; request.responseSize = kPayloadSize;
[GRPCCall setResponseSizeLimit:6 * 1024 * 1024 forHost:[[self class] host]]; [GRPCCall setResponseSizeLimit:6 * 1024 * 1024 forHost:[[self class] host]];
[_service unaryCallWithRequest:request [_service unaryCallWithRequest:request
handler:^(RMTSimpleResponse *response, NSError *error) { handler:^(RMTSimpleResponse *response, NSError *error) {
XCTAssertNil(error, @"Finished with unexpected error: %@", error); callError = error;
XCTAssertEqual(response.payload.body.length, kPayloadSize);
[expectation fulfill]; [expectation fulfill];
}]; }];
[self waitForExpectationsWithTimeout:TEST_TIMEOUT handler:nil]; [self waitForExpectationsWithTimeout:TEST_TIMEOUT handler:nil];
XCTAssertNil(callError, @"Finished with unexpected error: %@", callError);
} }
- (void)testClientStreamingRPC { - (void)testClientStreamingRPC {

Loading…
Cancel
Save