Return on subscription abort (bluesky-social#921)

return on subscription abort
sarvex · Apr 28, 2023 · 63bef85 · 63bef85
1 parent 6b3d5c1
commit 63bef85
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/packages/pds/src/sequencer/outbox.ts b/packages/pds/src/sequencer/outbox.ts
@@ -35,6 +35,7 @@ export class Outbox {
     // catch up as much as we can
     if (backfillCursor !== undefined) {
       for await (const evt of this.getBackfill(backfillCursor, backFillTime)) {
+        if (signal?.aborted) return
         this.lastSeen = evt.seq
         yield evt
       }
@@ -81,6 +82,7 @@ export class Outbox {
     while (true) {
       try {
         for await (const evt of this.outBuffer.events()) {
+          if (signal?.aborted) return
           if (evt.seq > this.lastSeen) {
             this.lastSeen = evt.seq
             yield evt