Enable eslint rule and reject with errors instead of strings

eslint.config.mjs

@@ -14,7 +14,7 @@ export default [
             '@typescript-eslint/no-unsafe-member-access': 'off',
             '@typescript-eslint/no-unsafe-return': 'off',
             '@typescript-eslint/only-throw-error': 'off',
-            '@typescript-eslint/prefer-promise-reject-errors': 'off',
+            '@typescript-eslint/prefer-promise-reject-errors': 'error',
             '@typescript-eslint/restrict-plus-operands': 'error',
             '@typescript-eslint/restrict-template-expressions': 'error',
             '@typescript-eslint/unbound-method': 'off',

examples/rpc-transport-throttled/src/example.ts

@@ -94,6 +94,7 @@ function getThrottledTransport<TClusterUrl extends ClusterUrl>(
             } as QueuedRequest<TClusterUrl>);
             if (config.signal) {
                 config.signal.addEventListener('abort', function () {
+                    // eslint-disable-next-line @typescript-eslint/prefer-promise-reject-errors
                     reject(this.reason);
                 });
             }

packages/promises/src/abortable.ts

@@ -10,9 +10,11 @@ export function getAbortablePromise<T>(promise: Promise<T>, abortSignal?: AbortS
             // want to throw even if the input promise's result is ready
             new Promise<never>((_, reject) => {
                 if (abortSignal.aborted) {
+                    // eslint-disable-next-line @typescript-eslint/prefer-promise-reject-errors
                     reject(abortSignal.reason);
                 } else {
                     abortSignal.addEventListener('abort', function () {
+                        // eslint-disable-next-line @typescript-eslint/prefer-promise-reject-errors
                         reject(this.reason);
                     });
                 }

packages/rpc-subscriptions-channel-websocket/src/websocket-channel.ts

@@ -25,6 +25,7 @@ export function createWebSocketChannel({
     url,
 }: Config): Promise<RpcSubscriptionsChannel<WebSocketMessage, string>> {
     if (signal.aborted) {
+        // eslint-disable-next-line @typescript-eslint/prefer-promise-reject-errors
         return Promise.reject(signal.reason);
     }
     let bufferDrainWatcher: Readonly<{ onCancel(): void; promise: Promise<void> }> | undefined;

packages/rpc-subscriptions-spec/src/rpc-subscriptions-pubsub-plan.ts

@@ -135,6 +135,7 @@ export async function executeRpcPubSubSubscriptionPlan<TNotification>({
                 subscriptionId = undefined;
                 channel.send(unsubscribePayload).catch(() => {});
             }
+            // eslint-disable-next-line @typescript-eslint/prefer-promise-reject-errors
             reject(this.reason);
         }
         if (signal.aborted) {

packages/rpc/src/__tests__/rpc-request-coalescer-test.ts

@@ -110,6 +110,7 @@ describe('RPC request coalescer', () => {
                     return await new Promise((resolve, reject) => {
                         transportResponsePromise = resolve;
                         signal?.addEventListener('abort', (e: AbortSignalEventMap['abort']) => {
+                            // eslint-disable-next-line @typescript-eslint/prefer-promise-reject-errors
                             reject((e.target as AbortSignal).reason);
                         });
                     });

packages/rpc/src/rpc-request-coalescer.ts

@@ -84,6 +84,7 @@ export function getRpcTransportWithRequestCoalescing<TTransport extends RpcTrans
                             abortController.abort((EXPLICIT_ABORT_TOKEN ||= createExplicitAbortToken()));
                         }
                     });
+                    // eslint-disable-next-line @typescript-eslint/prefer-promise-reject-errors
                     reject((e.target as AbortSignal).reason);
                 };
                 signal.addEventListener('abort', handleAbort);