Function safeSend

apps/webapp/app/utils/sse.server.ts:36–60

(args: { event?: string; data: string })

  return eventStream(request.signal, (send, close) => {
    const safeSend = (args: { event?: string; data: string }) => {
      try {
        send(args);
      } catch (error) {
        if (error instanceof Error) {
          if (error.name !== "TypeError") {
            logger.debug("Error sending SSE, aborting", {
              error: {
                name: error.name,
                message: error.message,
                stack: error.stack,
              },
              args,
            });
          }
        } else {
          logger.debug("Unknown error sending SSE, aborting", {
            error,
            args,
          });
        }

        close();
      }
    };

    pinger = setInterval(() => {
      if (request.signal.aborted) {