feat: force flush tick

Author: arifBurakDemiray

sdk/src/main/java/ly/count/android/sdk/ConnectionQueue.java

@@ -887,6 +887,15 @@ void ensureExecutor() {
      * Should only be called if SDK is initialized
      */
     public void tick() {
+        tick(false);
+    }
+
+    /**
+     * This function blocks caller until RQ flushes, so be cautious when using it.
+     *
+     * @param forceFlushRQ if true, will block until RQ is fully flushed
+     */
+    public void tick(boolean forceFlushRQ) {
         //todo enable later
         //assert storageProvider != null;
         if (backoff_.get()) {
@@ -906,8 +915,17 @@ public void tick() {
 
         if (!rqEmpty && (connectionProcessorFuture_ == null || cpDoneIfOngoing)) {
             L.d("[ConnectionQueue] tick, Starting ConnectionProcessor");
-            ensureExecutor();
-            connectionProcessorFuture_ = executor_.submit(createConnectionProcessor());
+            Runnable cp = createConnectionProcessor();
+            if (forceFlushRQ) {
+                try {
+                    cp.run();
+                } catch (Exception e) {
+                    L.e("[ConnectionQueue] tick, forceFlushRQ encountered an error: " + e.getMessage());
+                }
+            } else {
+                ensureExecutor();
+                connectionProcessorFuture_ = executor_.submit(cp);
+            }
         }
     }
 

sdk/src/main/java/ly/count/android/sdk/RequestQueueProvider.java

@@ -52,6 +52,8 @@ interface RequestQueueProvider {
 
     void tick();
 
+    void tick(boolean forceFlushRQ);
+
     ConnectionProcessor createConnectionProcessor();
 
     String prepareRemoteConfigRequestLegacy(@Nullable String keysInclude, @Nullable String keysExclude, @NonNull String preparedMetrics);