chore: comments

Author: durran

src/cmap/commands.ts

@@ -732,15 +732,15 @@ const COMPRESSION_DETAILS_SIZE = 9; // originalOpcode + uncompressedSize, compre
  */
 export class OpCompressedRequest {
   private command: WriteProtocolMessageType;
-  private options: { zLibCompressionLevel: number; agreedCompressor: CompressorName };
+  private options: { zlibCompressionLevel: number; agreedCompressor: CompressorName };
 
   constructor(
     command: WriteProtocolMessageType,
     options: { zlibCompressionLevel: number; agreedCompressor: CompressorName }
   ) {
     this.command = command;
     this.options = {
-      zLibCompressionLevel: options.zlibCompressionLevel,
+      zlibCompressionLevel: options.zlibCompressionLevel,
       agreedCompressor: options.agreedCompressor
     };
   }
@@ -762,13 +762,7 @@ export class OpCompressedRequest {
     const originalCommandOpCode = concatenatedOriginalCommandBuffer.readInt32LE(12);
 
     // Compress the message body
-    const compressedMessage = await compress(
-      {
-        zlibCompressionLevel: this.options.zLibCompressionLevel,
-        agreedCompressor: this.options.agreedCompressor
-      },
-      messageToBeCompressed
-    );
+    const compressedMessage = await compress(this.options, messageToBeCompressed);
     // Create the msgHeader of OP_COMPRESSED
     const msgHeader = Buffer.alloc(MESSAGE_HEADER_SIZE);
     msgHeader.writeInt32LE(

src/cmap/wire_protocol/on_data.ts

@@ -89,8 +89,9 @@ export function onData(
       return this;
     },
 
-    [Symbol.asyncDispose]: function (): PromiseLike<void> {
-      return closeHandler().then(() => undefined);
+    // Note this should currently not be used, but is required by the AsyncGenerator interface.
+    async [Symbol.asyncDispose]() {
+      await closeHandler();
     }
   };