diff options
author | 2015-05-08 10:40:01 -0700 | |
---|---|---|
committer | 2015-05-08 10:40:01 -0700 | |
commit | 6b54244a11c434c888929dc0c858cec776d48e0c (patch) | |
tree | b6cab5aac3fb5747cf01f8693e4cdeeec4ab5959 /src/objective-c/GRPCClient/private/GRPCCompletionQueue.m | |
parent | cc82be534e88327d9db791d5e7fb8752dd390a3e (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.m | 11 |
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:@""]; } }; |