|
|
@ -683,11 +683,11 @@ const char *kCFStreamVarName = "grpc_cfstream"; |
|
|
|
dispatch_async(_callQueue, ^{ |
|
|
|
dispatch_async(_callQueue, ^{ |
|
|
|
__weak GRPCCall *weakSelf = self; |
|
|
|
__weak GRPCCall *weakSelf = self; |
|
|
|
[self startReadWithHandler:^(grpc_byte_buffer *message) { |
|
|
|
[self startReadWithHandler:^(grpc_byte_buffer *message) { |
|
|
|
__strong GRPCCall *strongSelf = weakSelf; |
|
|
|
|
|
|
|
if (message == NULL) { |
|
|
|
if (message == NULL) { |
|
|
|
// No more messages from the server |
|
|
|
// No more messages from the server |
|
|
|
return; |
|
|
|
return; |
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
__strong GRPCCall *strongSelf = weakSelf; |
|
|
|
if (strongSelf == nil) { |
|
|
|
if (strongSelf == nil) { |
|
|
|
grpc_byte_buffer_destroy(message); |
|
|
|
grpc_byte_buffer_destroy(message); |
|
|
|
return; |
|
|
|
return; |
|
|
|