Function test

test/integration/node-specific/abort_signal.test.ts:303–345

(cursorAPI, args)

        const metadata: MongoDBMetadataUI = { requires: { topology: class="st">'replicaset' } };

        function test(cursorAPI, args) {
          let controller: AbortController;
          let signal: AbortSignal;
          let cursor: AbstractCursor<{ a: number }>;

          beforeEach(() => {
            controller = new AbortController();
            signal = controller.signal;
            cursor = method(filter, {
              signal,
              class="cm">// Pick an unselectable server
              readPreference: new ReadPreference(class="st">'secondary', [
                { something: class="st">'that does not exist' }
              ])
            });
          });

          afterEach(async () => {
            await cursor?.close();
          });

          it(`rejects ${cursorAPI.toString()}`, metadata, async () => {
            const willBeResult = iterateUntilDocumentOrError(cursor, cursorAPI, args);

            await sleep(3);
            expect(
              findLast(
                logs,
                l =>
                  l.operation === cursorName &&
                  l.message === class="st">'Waiting for suitable server to become available'
              )
            ).to.exist;

            controller.abort();
            const start = performance.now();
            const result = await willBeResult;
            const end = performance.now();
            expect(end - start).to.be.lessThan(10); class="cm">// should be way less than 5s server selection timeout

            expect(result).to.be.instanceOf(DOMException);
          });
        }

        for (const [cursorAPI, { value: args }] of getAllProps(cursorAPIs)) {
          test(cursorAPI, args);