fix: Fixed undefined option handling.

src/network/connection.ts

@@ -122,7 +122,7 @@ export class Connection extends EventEmitter {
     this.#correlationId = 0
     this.#nextMessage = 0
     this.#afterDrainRequests = []
-    this.#requestsQueue = fastq((op, cb) => op(cb), this.#options.maxInflights!)
+    this.#requestsQueue = fastq((op, cb) => op(cb), this.#options.maxInflights! ?? defaultOptions.maxInflights!)
     this.#inflightRequests = new Map()
     this.#responseBuffer = new DynamicBuffer()
     this.#responseReader = new Reader(this.#responseBuffer)

test/clients/base/base.test.ts

@@ -750,3 +750,23 @@ test('kPerformWithRetry should not leak timers', async t => {
   strictEqual(error.errors.length, 2)
   ok(error.errors[1].message.startsWith('Client closed while retrying'))
 })
+
+test('initialization should not fail when maxInflights is specifically set to undefined', async t => {
+  const client = createBase(t, { maxInflights: undefined })
+
+  // Create a promise that resolves when metadata event is emitted
+  const metadataPromise = new Promise<ClusterMetadata>(resolve => {
+    client.on('client:metadata', resolve)
+  })
+
+  // Trigger metadata fetch
+  client.metadata({ topics: [] })
+
+  // Wait for the event
+  const metadata = await metadataPromise
+
+  // Verify metadata structure
+  strictEqual(typeof metadata.id, 'string')
+  strictEqual(metadata.brokers instanceof Map, true)
+  strictEqual(metadata.topics instanceof Map, true)
+})