aboutsummaryrefslogtreecommitdiffhomepage
path: root/src/objective-c/GRPCClient/GRPCCall.m
diff options
context:
space:
mode:
authorGravatar Muxi Yan <mxyan@google.com>2018-12-06 13:08:34 -0800
committerGravatar Muxi Yan <mxyan@google.com>2018-12-06 13:10:57 -0800
commiteeced98fc556c6a5bc3a5dedc171c98747217078 (patch)
tree4d9c1df2c6a46b10b8ea4d3ade38012bcaef41b6 /src/objective-c/GRPCClient/GRPCCall.m
parent76f1ec16e1880605215beb60a204b0cab7c36b2d (diff)
Rename handlers to didXxx
Diffstat (limited to 'src/objective-c/GRPCClient/GRPCCall.m')
-rw-r--r--src/objective-c/GRPCClient/GRPCCall.m16
1 files changed, 8 insertions, 8 deletions
diff --git a/src/objective-c/GRPCClient/GRPCCall.m b/src/objective-c/GRPCClient/GRPCCall.m
index 9b3bcd385e..48253677bd 100644
--- a/src/objective-c/GRPCClient/GRPCCall.m
+++ b/src/objective-c/GRPCClient/GRPCCall.m
@@ -250,7 +250,7 @@ const char *kCFStreamVarName = "grpc_cfstream";
_call = nil;
_pipe = nil;
- if ([_handler respondsToSelector:@selector(closedWithTrailingMetadata:error:)]) {
+ if ([_handler respondsToSelector:@selector(didCloseWithTrailingMetadata:error:)]) {
dispatch_async(_dispatchQueue, ^{
// Copy to local so that block is freed after cancellation completes.
id<GRPCResponseHandler> copiedHandler = nil;
@@ -259,7 +259,7 @@ const char *kCFStreamVarName = "grpc_cfstream";
self->_handler = nil;
}
- [copiedHandler closedWithTrailingMetadata:nil
+ [copiedHandler didCloseWithTrailingMetadata:nil
error:[NSError errorWithDomain:kGRPCErrorDomain
code:GRPCErrorCodeCancelled
userInfo:@{
@@ -321,13 +321,13 @@ const char *kCFStreamVarName = "grpc_cfstream";
- (void)issueInitialMetadata:(NSDictionary *)initialMetadata {
@synchronized(self) {
if (initialMetadata != nil &&
- [_handler respondsToSelector:@selector(receivedInitialMetadata:)]) {
+ [_handler respondsToSelector:@selector(didReceiveInitialMetadata:)]) {
dispatch_async(_dispatchQueue, ^{
id<GRPCResponseHandler> copiedHandler = nil;
@synchronized(self) {
copiedHandler = self->_handler;
}
- [copiedHandler receivedInitialMetadata:initialMetadata];
+ [copiedHandler didReceiveInitialMetadata:initialMetadata];
});
}
}
@@ -335,13 +335,13 @@ const char *kCFStreamVarName = "grpc_cfstream";
- (void)issueMessage:(id)message {
@synchronized(self) {
- if (message != nil && [_handler respondsToSelector:@selector(receivedRawMessage:)]) {
+ if (message != nil && [_handler respondsToSelector:@selector(didReceiveRawMessage:)]) {
dispatch_async(_dispatchQueue, ^{
id<GRPCResponseHandler> copiedHandler = nil;
@synchronized(self) {
copiedHandler = self->_handler;
}
- [copiedHandler receivedRawMessage:message];
+ [copiedHandler didReceiveRawMessage:message];
});
}
}
@@ -349,7 +349,7 @@ const char *kCFStreamVarName = "grpc_cfstream";
- (void)issueClosedWithTrailingMetadata:(NSDictionary *)trailingMetadata error:(NSError *)error {
@synchronized(self) {
- if ([_handler respondsToSelector:@selector(closedWithTrailingMetadata:error:)]) {
+ if ([_handler respondsToSelector:@selector(didCloseWithTrailingMetadata:error:)]) {
dispatch_async(_dispatchQueue, ^{
id<GRPCResponseHandler> copiedHandler = nil;
@synchronized(self) {
@@ -357,7 +357,7 @@ const char *kCFStreamVarName = "grpc_cfstream";
// Clean up _handler so that no more responses are reported to the handler.
self->_handler = nil;
}
- [copiedHandler closedWithTrailingMetadata:trailingMetadata error:error];
+ [copiedHandler didCloseWithTrailingMetadata:trailingMetadata error:error];
});
} else {
_handler = nil;