minor cleanup

packages/host/app/lib/browser-queue.ts

@@ -28,6 +28,7 @@ export class BrowserQueue implements Queue {
   get isDestroyed() {
     return this.#isDestroyed;
   }
+
   get hasStarted() {
     return this.#hasStarted;
   }
@@ -76,7 +77,7 @@ export class BrowserQueue implements Queue {
   }, 250);
 
   private async drainJobs() {
-    await this.#flush;
+    await this.flush();
 
     let jobsDrained: () => void;
     this.#flush = new Promise((res) => (jobsDrained = res));
@@ -106,6 +107,6 @@ export class BrowserQueue implements Queue {
 
   async destroy() {
     this.#isDestroyed = true;
-    await this.#flush;
+    await this.flush();
   }
 }

packages/host/tests/unit/queue-test.ts

@@ -26,14 +26,14 @@ module('Unit | queue | browser implementation', function (hooks) {
   });
 
   test(`a job can throw an exception`, async function (assert) {
+    queue.register('increment', async (a: number) => a + 1);
     queue.register('boom', async () => {
       throw new Error('boom!');
     });
     let [errorJob, nonErrorJob] = await Promise.all([
       queue.publish<number>('boom', null),
       queue.publish<number>('increment', 17),
     ]);
-    queue.register('increment', async (a: number) => a + 1);
 
     // assert that the error that was thrown does not prevent subsequent jobs
     // from running

packages/runtime-common/package.json

@@ -48,7 +48,6 @@
     "recast": "^0.23.4",
     "super-fast-md5": "^1.0.1",
     "transform-modules-amd-plugin": "workspace:*",
-    "typescript-memoize": "^1.1.1",
     "uuid": "^9.0.1"
   },
   "devDependencies": {

packages/runtime-common/queue.ts

@@ -1,5 +1,4 @@
 import { PgPrimitive } from './expression';
-import { Memoize } from 'typescript-memoize';
 import { Deferred } from './deferred';
 
 export interface QueueOpts {
@@ -31,7 +30,6 @@ export class Job<T> {
     public uuid: string,
     private notifier: Deferred<T>,
   ) {}
-  @Memoize()
   get done(): Promise<T> {
     return this.notifier.promise;
   }