[TEST] fix some flappers that are sensitive to machine load

jetstream.md

@@ -10,9 +10,9 @@ Messages are replayed from a stream by _consumers_. A consumer configuration
 specifies which messages should be presented. For example a consumer may only be
 interested in viewing messages from a specific sequence or starting from a
 specific time, or having a specific subject. The configuration also specifies if
-the server should require messages to be acknowledged and how long to wait
-for acknowledgements. The consumer configuration also specifies options to
-control the rate at which messages are presented to the client.
+the server should require messages to be acknowledged and how long to wait for
+acknowledgements. The consumer configuration also specifies options to control
+the rate at which messages are presented to the client.
 
 For more information about JetStream, please visit the
 [JetStream repo](https://github.com/nats-io/jetstream).

nats-base-client/util.ts

@@ -126,6 +126,16 @@ export function delay(ms = 0): Promise<void> {
   });
 }
 
+export function deadline<T>(p: Promise<T>, millis = 1000): Promise<T> {
+  const err = new Error(`deadline exceeded`);
+  const d = deferred<never>();
+  const timer = setTimeout(
+    () => d.reject(err),
+    millis,
+  );
+  return Promise.race([p, d]).finally(() => clearTimeout(timer));
+}
+
 export interface Deferred<T> extends Promise<T> {
   /**
    * Resolves the Deferred to a value T