Merge pull request #6 from murgatroid99/objective_c_completion_queue_update

Updated Objective C code to match completion queue changes

src/objective-c/GRPCClient/private/GRPCCompletionQueue.h

@@ -34,7 +34,7 @@
 #import <Foundation/Foundation.h>
 #include <grpc/grpc.h>
 
-typedef void(^GRPCQueueCompletionHandler)(grpc_op_error error);
+typedef void(^GRPCQueueCompletionHandler)(bool success);
 
 // This class lets one more easily use grpc_completion_queue. To use it, pass
 // the value of the unmanagedQueue property of an instance of this class to

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 = (__bridge_transfer GRPCQueueCompletionHandler)event.tag;
-            handler(event->data.op_complete);
+            handler(event.success);
-            grpc_event_finish(event);
             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:@""];
         }
       };

src/objective-c/GRPCClient/private/GRPCWrappedCall.m

@@ -296,8 +296,8 @@
     [op getOp:&ops_array[i++]];
   }
   grpc_call_error error = grpc_call_start_batch(_call, ops_array, nops,
-                                                (__bridge_retained void *)(^(grpc_op_error error){
+                                                (__bridge_retained void *)(^(bool success){
-    if (error != GRPC_OP_OK) {
+    if (!success) {
       if (errorHandler) {
         errorHandler();
       } else {