File tree Expand file tree Collapse file tree 2 files changed +6
-6
lines changed
onesignal/src/main/java/com/onesignal
unittest/src/test/java/com/onesignal Expand file tree Collapse file tree 2 files changed +6
-6
lines changed Original file line number Diff line number Diff line change 18
18
import java .util .HashMap ;
19
19
import java .util .Queue ;
20
20
import java .util .Set ;
21
- import java .util .concurrent .ConcurrentLinkedQueue ;
21
+ import java .util .concurrent .LinkedBlockingQueue ;
22
22
import java .util .concurrent .atomic .AtomicBoolean ;
23
23
24
24
import static com .onesignal .OSInAppMessageController .IN_APP_MESSAGES_JSON_KEY ;
@@ -93,9 +93,9 @@ String getRegistrationId() {
93
93
94
94
// Maintain a list of handlers so that if the user calls
95
95
// sendTags() multiple times it will call each callback
96
- final private Queue <ChangeTagsUpdateHandler > sendTagsHandlers = new ConcurrentLinkedQueue <>();
97
- final private Queue <OneSignal .OSInternalExternalUserIdUpdateCompletionHandler > externalUserIdUpdateHandlers = new ConcurrentLinkedQueue <>();
98
- final private Queue <OSDeviceInfoCompletionHandler > deviceInfoCompletionHandler = new ConcurrentLinkedQueue <>();
96
+ final private Queue <ChangeTagsUpdateHandler > sendTagsHandlers = new LinkedBlockingQueue <>();
97
+ final private Queue <OneSignal .OSInternalExternalUserIdUpdateCompletionHandler > externalUserIdUpdateHandlers = new LinkedBlockingQueue <>();
98
+ final private Queue <OSDeviceInfoCompletionHandler > deviceInfoCompletionHandler = new LinkedBlockingQueue <>();
99
99
100
100
boolean hasQueuedHandlers () {
101
101
return externalUserIdUpdateHandlers .size () > 0 ;
Original file line number Diff line number Diff line change 22
22
import java .util .ArrayList ;
23
23
import java .util .List ;
24
24
import java .util .Map ;
25
+ import java .util .Queue ;
25
26
import java .util .Set ;
26
- import java .util .concurrent .ConcurrentLinkedQueue ;
27
27
28
28
import static com .test .onesignal .TestHelpers .threadAndTaskWait ;
29
29
import static org .robolectric .Shadows .shadowOf ;
@@ -295,7 +295,7 @@ public static DelayedConsentInitializationParameters OneSignal_delayedInitParams
295
295
return OneSignal .getDelayedInitParams ();
296
296
}
297
297
298
- public static ConcurrentLinkedQueue <Runnable > OneSignal_taskQueueWaitingForInit () {
298
+ public static Queue <Runnable > OneSignal_taskQueueWaitingForInit () {
299
299
return OneSignal .getTaskRemoteController ().getTaskQueueWaitingForInit ();
300
300
}
301
301
You can’t perform that action at this time.
0 commit comments