|
|
@@ -82,12 +82,12 @@ extension ClientTimeoutTests {
|
|
|
func testBidirectionalStreamingTimeoutPassedToReceiveMethod() {
|
|
|
let completionHandlerExpectation = expectation(description: "final completion handler called")
|
|
|
let call = try! client.update { callResult in
|
|
|
- XCTAssertEqual(.deadlineExceeded, callResult.statusCode)
|
|
|
+ XCTAssertEqual(.ok, callResult.statusCode)
|
|
|
completionHandlerExpectation.fulfill()
|
|
|
}
|
|
|
|
|
|
do {
|
|
|
- let result = try call.receive(timeout: .now() + .milliseconds(50))
|
|
|
+ let result = try call.receive(timeout: .now() + .milliseconds(10))
|
|
|
XCTFail("should have thrown, received \(String(describing: result)) instead")
|
|
|
} catch let receiveError {
|
|
|
if case .timedOut = receiveError as! RPCError {
|
|
|
@@ -96,6 +96,8 @@ extension ClientTimeoutTests {
|
|
|
XCTFail("received error \(receiveError) instead of .timedOut")
|
|
|
}
|
|
|
}
|
|
|
+
|
|
|
+ try! call.closeSend()
|
|
|
|
|
|
waitForExpectations(timeout: defaultTimeout)
|
|
|
}
|