address wenxi's comments

Author: abueide

packages/core/src/analytics.ts

@@ -509,12 +509,7 @@ export class SegmentClient {
     if (this.enabled.get() === false) {
       return;
     }
-    if (!this.running.get()) {
-      // If not running, queue the event for later processing
-      await this.store.pendingEvents.add(event);
-      return event;
-    }
-    if (this.isReady.value) {
+    if (!this.running.get() || !this.isReady.value) {
       return this.startTimelineProcessing(event);
     } else {
       this.store.pendingEvents.add(event);
@@ -532,7 +527,7 @@ export class SegmentClient {
   ): Promise<SegmentEvent | undefined> {
     const event = await this.applyContextData(incomingEvent);
     this.flushPolicyExecuter.notify(event);
-    return await this.timeline.process(event);
+    return this.timeline.process(event);
   }
 
   private async trackDeepLinks() {

packages/core/src/plugins/QueueFlushingPlugin.ts

@@ -73,13 +73,6 @@ export class QueueFlushingPlugin extends UtilityPlugin {
    * Calls the onFlush callback with the events in the queue
    */
   async flush() {
-    // Check if event processing is running
-    const running = this.analytics?.running.get();
-    if (running === false) {
-      this.analytics?.logger.info('Event processing is paused, skipping flush');
-      return;
-    }
-
     // Wait for the queue to be restored
     try {
       await this.isRestored;