aboutsummaryrefslogtreecommitdiffhomepage
path: root/src/objective-c/tests/GRPCClientTests.m
diff options
context:
space:
mode:
authorGravatar Muxi Yan <mxyan@google.com>2018-10-23 10:22:18 -0700
committerGravatar Muxi Yan <mxyan@google.com>2018-10-23 10:22:18 -0700
commitf3e9224f0b34a6265830600c67293d96964a4c5c (patch)
tree0523ee249312046d7710cfe8bcb9a4af042940d1 /src/objective-c/tests/GRPCClientTests.m
parente39c146f0f7f1a56e0cd65ec5d707c8bb091366e (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.m24
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 {