package.json

@@ -9,7 +9,6 @@
     "concat-stream": "^2.0.0",
     "es6-error": "^4.1.1",
     "iso8601-duration": "^1.3.0",
-    "p-defer": "^3.0.0",
     "pg": "^8.11.0",
     "pg-cursor": "^2.10.0",
     "pg-protocol": "^1.6.0",

src/routines/executeQuery.ts

@@ -26,8 +26,8 @@ import {
   type QuerySqlToken,
 } from '../types';
 import { createQueryId } from '../utilities/createQueryId';
+import { defer } from '../utilities/defer';
 import { getStackTrace } from '../utilities/getStackTrace';
-import Deferred from 'p-defer';
 import { type PoolClient as PgPoolClient } from 'pg';
 import { serializeError } from 'serialize-error';
 
@@ -211,7 +211,7 @@ export const executeQuery = async (
     notices.push(notice);
   };
 
-  const activeQuery = Deferred();
+  const activeQuery = defer<null>();
 
   const blockingPromise = poolClientState.activeQuery?.promise ?? null;
 
@@ -328,7 +328,7 @@ export const executeQuery = async (
     } finally {
       connection.off('notice', noticeListener);
 
-      activeQuery.resolve();
+      activeQuery.resolve(null);
     }
   } catch (error) {
     for (const interceptor of clientConfiguration.interceptors) {

src/state.ts

@@ -1,6 +1,6 @@
 import { UnexpectedStateError } from './errors';
 import { type TypeOverrides } from './types';
-import { type DeferredPromise } from 'p-defer';
+import { type DeferredPromise } from './utilities/defer';
 import { type Pool as PgPool, type PoolClient as PgClientPool } from 'pg';
 
 type PoolState = {
@@ -11,7 +11,7 @@ type PoolState = {
 };
 
 type PoolClientState = {
-  activeQuery?: DeferredPromise<unknown>;
+  activeQuery?: DeferredPromise<null>;
   connectionId: string;
   mock: boolean;
   poolId: string;

src/utilities/defer.ts

@@ -0,0 +1,16 @@
+export type DeferredPromise<ValueType> = {
+  promise: Promise<ValueType>;
+  reject: (error: unknown) => void;
+  resolve: (value: ValueType) => void;
+};
+
+export const defer = <T>(): DeferredPromise<T> => {
+  const deferred = {} as DeferredPromise<T>;
+
+  deferred.promise = new Promise((resolve, reject) => {
+    deferred.resolve = resolve;
+    deferred.reject = reject;
+  });
+
+  return deferred;
+};