allow for negative duration Timeout

mongodb · Jul 29, 2024 · 5fc6471 · 5fc6471
1 parent 5505c68
commit 5fc6471
Showing 1 changed file with 3 additions and 5 deletions.
diff --git a/src/timeout.ts b/src/timeout.ts
@@ -1,6 +1,6 @@
 import { clearTimeout, setTimeout } from 'timers';
 
-import { MongoOperationTimeoutError, MongoRuntimeError } from './error';
+import { MongoRuntimeError } from './error';
 import { noop } from './utils';
 
 /** @internal */
@@ -260,15 +260,13 @@ export class CSOTTimeoutContext extends TimeoutContext {
   get timeoutForSocketWrite(): Timeout | null {
     const { remainingTimeMS } = this;
     if (!Number.isFinite(remainingTimeMS)) return null;
-    if (remainingTimeMS > 0) return Timeout.expires(remainingTimeMS);
-    throw new MongoOperationTimeoutError('Timed out before socket write');
+    return Timeout.expires(remainingTimeMS);
   }
 
   get timeoutForSocketRead(): Timeout | null {
     const { remainingTimeMS } = this;
     if (!Number.isFinite(remainingTimeMS)) return null;
-    if (remainingTimeMS > 0) return Timeout.expires(remainingTimeMS);
-    throw new MongoOperationTimeoutError('Timed out before socket read');
+    return Timeout.expires(remainingTimeMS);
   }
 }