From 04925a580b2e15d8536f4505f440269c11e0b29b Mon Sep 17 00:00:00 2001
From: Alex Gleason <alex@alexgleason.me>
Date: Sat, 23 Dec 2023 11:16:18 -0600
Subject: [PATCH] Reqmeister: timeout -> signal

---
 src/common.ts     | 2 +-
 src/reqmeister.ts | 4 ++--
 2 files changed, 3 insertions(+), 3 deletions(-)

diff --git a/src/common.ts b/src/common.ts
index 14614597..0424b524 100644
--- a/src/common.ts
+++ b/src/common.ts
@@ -3,7 +3,7 @@ import { Time } from '@/utils/time.ts';
 
 const reqmeister = new Reqmeister({
   delay: Time.seconds(1),
-  timeout: Time.seconds(1),
+  signal: AbortSignal.timeout(Time.seconds(1)),
 });
 
 export { reqmeister };
diff --git a/src/reqmeister.ts b/src/reqmeister.ts
index f7f469e1..eb1f26d7 100644
--- a/src/reqmeister.ts
+++ b/src/reqmeister.ts
@@ -6,7 +6,7 @@ import { eventToMicroFilter, getFilterId, type MicroFilter } from '@/filter.ts';
 
 interface ReqmeisterOpts {
   delay?: number;
-  timeout?: number;
+  signal?: AbortSignal;
 }
 
 type ReqmeisterQueueItem = [string, MicroFilter, WebSocket['url'][]];
@@ -55,7 +55,7 @@ class Reqmeister extends EventEmitter<{ [filterId: string]: (event: Event) => an
     if (wantedEvents.size) filters.push({ ids: [...wantedEvents] });
     if (wantedAuthors.size) filters.push({ kinds: [0], authors: [...wantedAuthors] });
 
-    const events = await client.getFilters(filters, { timeout: this.#opts.timeout });
+    const events = await client.getFilters(filters, { signal: this.#opts.signal });
 
     for (const event of events) {
       this.encounter(event);