diff options
author | Muxi Yan <mxyan@google.com> | 2018-10-23 10:22:18 -0700 |
---|---|---|
committer | Muxi Yan <mxyan@google.com> | 2018-10-23 10:22:18 -0700 |
commit | f3e9224f0b34a6265830600c67293d96964a4c5c (patch) | |
tree | 0523ee249312046d7710cfe8bcb9a4af042940d1 /src/objective-c/tests/GRPCClientTests.m | |
parent | e39c146f0f7f1a56e0cd65ec5d707c8bb091366e (diff) |
Remove retain of handler in callbacks and dispatch to dispatchQueue
Diffstat (limited to 'src/objective-c/tests/GRPCClientTests.m')
-rw-r--r-- | src/objective-c/tests/GRPCClientTests.m | 24 |
1 files changed, 15 insertions, 9 deletions
diff --git a/src/objective-c/tests/GRPCClientTests.m b/src/objective-c/tests/GRPCClientTests.m index 2021540f28..bbe81502dc 100644 --- a/src/objective-c/tests/GRPCClientTests.m +++ b/src/objective-c/tests/GRPCClientTests.m @@ -115,22 +115,28 @@ static GRPCProtoMethod *kFullDuplexCallMethod; } - (void)receivedInitialMetadata:(NSDictionary *_Nullable)initialMetadata { - if (_initialMetadataCallback) { - _initialMetadataCallback(initialMetadata); - } + dispatch_async(_dispatchQueue, ^{ + if (_initialMetadataCallback) { + _initialMetadataCallback(initialMetadata); + } + }); } - (void)receivedRawMessage:(GPBMessage *_Nullable)message { - if (_messageCallback) { - _messageCallback(message); - } + dispatch_async(_dispatchQueue, ^{ + if (_messageCallback) { + _messageCallback(message); + } + }); } - (void)closedWithTrailingMetadata:(NSDictionary *_Nullable)trailingMetadata error:(NSError *_Nullable)error { - if (_closeCallback) { - _closeCallback(trailingMetadata, error); - } + dispatch_async(_dispatchQueue, ^{ + if (_closeCallback) { + _closeCallback(trailingMetadata, error); + } + }); } - (dispatch_queue_t)dispatchQueue { |