chore: lint

Author: nbbeeken

src/cmap/wire_protocol/responses.ts

@@ -120,6 +120,7 @@ function throwUnsupportedError() {
   throw new Error('Unsupported method');
 }
 
+/** @internal */
 export class CursorResponse extends MongoDBResponse {
   public id: Long | null = null;
   public ns: MongoDBNamespace | null = null;

src/cursor/abstract_cursor.ts

@@ -961,7 +961,7 @@ class ReadableCursorStream extends Readable {
 
   private _readNext() {
     // eslint-disable-next-line github/no-then
-    next(this._cursor, { blocking: true, transform: true }).then(
+    next(this._cursor, { blocking: true, transform: true, hasNext: false }).then(
       result => {
         if (result == null) {
           this.push(null);

src/cursor/run_command_cursor.ts

@@ -125,7 +125,8 @@ export class RunCommandCursor extends AbstractCursor {
     const getMoreOperation = new GetMoreOperation(this.namespace, this.id!, this.server!, {
       ...this.cursorOptions,
       session: this.session,
-      ...this.getMoreOptions
+      ...this.getMoreOptions,
+      useCursorResponse: false
     });
 
     return await executeOperation(this.client, getMoreOperation);

src/index.ts

@@ -290,7 +290,11 @@ export type { ConnectionPoolMetrics } from './cmap/metrics';
 export type { StreamDescription, StreamDescriptionOptions } from './cmap/stream_description';
 export type { CompressorName } from './cmap/wire_protocol/compression';
 export type { JSTypeOf, OnDemandDocument } from './cmap/wire_protocol/on_demand/document';
-export type { MongoDBResponse, MongoDBResponseConstructor } from './cmap/wire_protocol/responses';
+export type {
+  CursorResponse,
+  MongoDBResponse,
+  MongoDBResponseConstructor
+} from './cmap/wire_protocol/responses';
 export type { CollectionOptions, CollectionPrivate, ModifyResult } from './collection';
 export type {
   COMMAND_FAILED,