throw error instead of promise.reject in attemptTransaction

aditi-khare-mongoDB · aditi-khare-mongoDB · commit 29a8d553050f · 2024-04-12T15:20:51.000-04:00
diff --git a/src/sessions.ts b/src/sessions.ts
@@ -609,9 +609,7 @@ async function attemptTransaction<T>(
 
   if (!isPromiseLike(promise)) {
     await session.abortTransaction().catch(() => null);
-    return await Promise.reject(
-      new MongoInvalidArgumentError('Function provided to `withTransaction` must return a Promise')
-    );
+    throw new MongoInvalidArgumentError('Function provided to `withTransaction` must return a Promise');
   }
 
   try {

Original file line number	Diff line number	Diff line change
`@@ -609,9 +609,7 @@ async function attemptTransaction<T>(`
`609`	`609`
`610`	`610`	`if (!isPromiseLike(promise)) {`
`611`	`611`	`await session.abortTransaction().catch(() => null);`
`612`		`- return await Promise.reject(`
`613`		- new MongoInvalidArgumentError('Function provided to `withTransaction` must return a Promise')
`614`		`- );`
	`612`	+ throw new MongoInvalidArgumentError('Function provided to `withTransaction` must return a Promise');
`615`	`613`	`}`
`616`	`614`
`617`	`615`	`try {`