fix(beszel): avoid blocking subscription teardown
This commit is contained in:
1 parent
f3ac40c527
commit
9bfb8f273c
1 file changed
+1
-3
@@ -227,11 +227,10 @@ export const beszelRouter = createTRPCRouter({
|
||||
systemId: input.systemId,
|
||||
});
|
||||
|
||||
let producer: Promise<void> | undefined;
|
||||
try {
|
||||
const instance = await createIntegrationAsync(integration);
|
||||
if (controller.signal.aborted) return;
|
||||
producer = (async () => {
|
||||
void (async () => {
|
||||
try {
|
||||
if (typeof instance.subscribeRealtimeMetrics !== "function") {
|
||||
throw new TRPCError({
|
||||
@@ -286,7 +285,6 @@ export const beszelRouter = createTRPCRouter({
|
||||
for await (const event of queue) yield event;
|
||||
} finally {
|
||||
stop();
|
||||
await producer?.catch(() => undefined);
|
||||
signal?.removeEventListener("abort", stop);
|
||||
logger.debug("Beszel realtime subscription stopped", {
|
||||
userId: ctx.session?.user?.id,
|
||||
|
||||
Reference in new issue
Block a user