aboutsummaryrefslogtreecommitdiffhomepage
path: root/src/objective-c/GRPCClient/private/GRPCCompletionQueue.m
diff options
context:
space:
mode:
authorGravatar murgatroid99 <mlumish@google.com>2015-05-08 10:40:01 -0700
committerGravatar murgatroid99 <mlumish@google.com>2015-05-08 10:40:01 -0700
commit6b54244a11c434c888929dc0c858cec776d48e0c (patch)
treeb6cab5aac3fb5747cf01f8693e4cdeeec4ab5959 /src/objective-c/GRPCClient/private/GRPCCompletionQueue.m
parentcc82be534e88327d9db791d5e7fb8752dd390a3e (diff)
Updated Objective C code to match completion queue changes
Diffstat (limited to 'src/objective-c/GRPCClient/private/GRPCCompletionQueue.m')
-rw-r--r--src/objective-c/GRPCClient/private/GRPCCompletionQueue.m11
1 files changed, 4 insertions, 7 deletions
diff --git a/src/objective-c/GRPCClient/private/GRPCCompletionQueue.m b/src/objective-c/GRPCClient/private/GRPCCompletionQueue.m
index a0a10164b1..40aade4f9a 100644
--- a/src/objective-c/GRPCClient/private/GRPCCompletionQueue.m
+++ b/src/objective-c/GRPCClient/private/GRPCCompletionQueue.m
@@ -65,20 +65,17 @@
dispatch_async(gDefaultConcurrentQueue, ^{
while (YES) {
// The following call blocks until an event is available.
- grpc_event *event = grpc_completion_queue_next(unmanagedQueue, gpr_inf_future);
+ grpc_event event = grpc_completion_queue_next(unmanagedQueue, gpr_inf_future);
GRPCQueueCompletionHandler handler;
- switch (event->type) {
+ switch (event.type) {
case GRPC_OP_COMPLETE:
- handler = (__bridge_transfer GRPCQueueCompletionHandler)event->tag;
- handler(event->data.op_complete);
- grpc_event_finish(event);
+ handler = (__bridge_transfer GRPCQueueCompletionHandler)event.tag;
+ handler(event.success);
break;
case GRPC_QUEUE_SHUTDOWN:
- grpc_event_finish(event);
grpc_completion_queue_destroy(unmanagedQueue);
return;
default:
- grpc_event_finish(event);
[NSException raise:@"Unrecognized completion type" format:@""];
}
};