Flush for analytics-node

analytics-node/analytics-node-tests.ts

@@ -80,3 +80,12 @@ function testIntegrations(): void {
     }
   });
 }
+
+function testFlush(): void {
+  analytics.flush();
+  analytics.flush(function(err, batch) {
+    if (err) { alert("Oh nos!"); }
+    else { console.log(batch.batch[0].type); }
+  });
+}
+

analytics-node/analytics-node.d.ts

@@ -65,6 +65,16 @@ declare module AnalyticsNode {
       anonymous_id?: string | number;
       integrations?: Integrations;
     }): Analytics;
+
+    /* Flush batched calls to make sure nothing is left in the queue */
+    flush(fn?: (err: Error, batch: {
+      batch: Array<{
+        type: string;
+      }>;
+      messageId: string;
+      sentAt: Date;
+      timestamp: Date;
+    }) => void): Analytics;
   }
 }