Skip to content

Commit 8eb0ca7

Browse files
committed
refac: synchronize sending (un)pausing in each handler
1 parent 1ac4d02 commit 8eb0ca7

File tree

4 files changed

+42
-10
lines changed

4 files changed

+42
-10
lines changed

Adjust/Internal/ADJAttributionHandler.m

Lines changed: 10 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -99,11 +99,19 @@ - (void)getAttribution {
9999
}
100100

101101
- (void)pauseSending {
102-
self.paused = YES;
102+
[ADJUtil launchInQueue:self.internalQueue
103+
selfInject:self
104+
block:^(ADJAttributionHandler* selfI) {
105+
selfI.paused = YES;
106+
}];
103107
}
104108

105109
- (void)resumeSending {
106-
self.paused = NO;
110+
[ADJUtil launchInQueue:self.internalQueue
111+
selfInject:self
112+
block:^(ADJAttributionHandler* selfI) {
113+
selfI.paused = NO;
114+
}];
107115
}
108116

109117
#pragma mark - internal

Adjust/Internal/ADJPackageHandler.m

Lines changed: 10 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -173,11 +173,19 @@ - (NSTimeInterval)retryPackageUsingBackoffWithResponse:(ADJResponseData *)respon
173173
}
174174

175175
- (void)pauseSending {
176-
self.paused = YES;
176+
[ADJUtil launchInQueue:self.internalQueue
177+
selfInject:self
178+
block:^(ADJPackageHandler* selfI) {
179+
selfI.paused = YES;
180+
}];
177181
}
178182

179183
- (void)resumeSending {
180-
self.paused = NO;
184+
[ADJUtil launchInQueue:self.internalQueue
185+
selfInject:self
186+
block:^(ADJPackageHandler* selfI) {
187+
selfI.paused = NO;
188+
}];
181189
}
182190

183191
- (void)updatePackagesWithAttStatus:(int)attStatus {

Adjust/Internal/ADJPurchaseVerificationHandler.m

Lines changed: 11 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -63,12 +63,20 @@ - (id)initWithActivityHandler:(id<ADJActivityHandler>)activityHandler
6363
}
6464

6565
- (void)pauseSending {
66-
self.paused = YES;
66+
[ADJUtil launchInQueue:self.internalQueue
67+
selfInject:self
68+
block:^(ADJPurchaseVerificationHandler *selfI) {
69+
selfI.paused = YES;
70+
}];
6771
}
6872

6973
- (void)resumeSending {
70-
self.paused = NO;
71-
[self sendNextPurchaseVerificationPackage];
74+
[ADJUtil launchInQueue:self.internalQueue
75+
selfInject:self
76+
block:^(ADJPurchaseVerificationHandler *selfI) {
77+
selfI.paused = NO;
78+
[selfI sendNextPurchaseVerificationPackage];
79+
}];
7280
}
7381

7482
- (void)sendPurchaseVerificationPackage:(ADJActivityPackage *)purchaseVerificationPackage {

Adjust/Internal/ADJSdkClickHandler.m

Lines changed: 11 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -66,12 +66,20 @@ - (id)initWithActivityHandler:(id<ADJActivityHandler>)activityHandler
6666
}
6767

6868
- (void)pauseSending {
69-
self.paused = YES;
69+
[ADJUtil launchInQueue:self.internalQueue
70+
selfInject:self
71+
block:^(ADJSdkClickHandler *selfI) {
72+
selfI.paused = YES;
73+
}];
7074
}
7175

7276
- (void)resumeSending {
73-
self.paused = NO;
74-
[self sendNextSdkClick];
77+
[ADJUtil launchInQueue:self.internalQueue
78+
selfInject:self
79+
block:^(ADJSdkClickHandler *selfI) {
80+
selfI.paused = NO;
81+
[selfI sendNextSdkClick];
82+
}];
7583
}
7684

7785
- (void)sendSdkClick:(ADJActivityPackage *)sdkClickPackage {

0 commit comments

Comments
 (0)