Skip to content

Commit 01a56ee

Browse files
committed
Another one slipped through the cracks
1 parent 895d678 commit 01a56ee

File tree

1 file changed

+2
-1
lines changed
  • grafast/dataplan-pg/src/adaptors

1 file changed

+2
-1
lines changed

grafast/dataplan-pg/src/adaptors/pg.ts

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -665,7 +665,8 @@ export class PgSubscriber<
665665
Object.values(this.topics).forEach((iterators) => {
666666
if (iterators) {
667667
for (const iterator of iterators) {
668-
iterator.throw!(e);
668+
const r = iterator.throw!(e);
669+
r.then(null, noop);
669670
}
670671
}
671672
});

0 commit comments

Comments
 (0)