[CORE] Use an interval not a timeout in flush

Author: Sytten

packages/apollo/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@graphmetrics/apollo",
-  "version": "0.2.0",
+  "version": "0.2.1",
   "main": "dist/index.js",
   "types": "dist/index.d.ts",
   "repository": "[email protected]:graphmetrics/graphmetrics-js.git",
@@ -18,7 +18,7 @@
     "dist"
   ],
   "dependencies": {
-    "@graphmetrics/core": "workspace:0.2.0",
+    "@graphmetrics/core": "workspace:0.2.1",
     "apollo-server-plugin-base": "0.10.4"
   },
   "peerDependencies": {

packages/core/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@graphmetrics/core",
-  "version": "0.2.0",
+  "version": "0.2.1",
   "main": "dist/index.js",
   "types": "dist/index.d.ts",
   "repository": "[email protected]:graphmetrics/graphmetrics-js.git",

packages/core/src/aggregator.ts

@@ -29,7 +29,7 @@ export class Aggregator {
 
     this.fieldQueue = new Denque<FieldMessage>();
     this.operationQueue = new Denque<OperationMessage>();
-    this.flushTimeout = setTimeout(this.flush.bind(this), FLUSH_INTERVAL);
+    this.flushTimeout = setInterval(this.flush.bind(this), FLUSH_INTERVAL);
     this.sender = new Sender(config);
 
     this.logger = config.logger ?? defaultLogger(config.advanced?.debug);
@@ -116,7 +116,7 @@ export class Aggregator {
 
   public async stop(): Promise<void> {
     this.logger.debug('Stopping aggregator');
-    clearTimeout(this.flushTimeout);
+    clearInterval(this.flushTimeout);
     while (this.fieldQueue.length > 0) this.processField();
     this.flush();
     await this.sender.stop();