Merge pull request #550 from nats-io/fix-no-mux-payload

[FIX] noMux option for request many elided request payload

nats-base-client/nats.ts

@@ -1,5 +1,5 @@
 /*
- * Copyright 2018-2022 The NATS Authors
+ * Copyright 2018-2023 The NATS Authors
  * Licensed under the Apache License, Version 2.0 (the "License");
  * you may not use this file except in compliance with the License.
  * You may obtain a copy of the License at
@@ -279,7 +279,7 @@ export class NatsConnectionImpl implements NatsConnection {
         });
 
       try {
-        this.publish(subject, Empty, { reply: sub.getSubject() });
+        this.publish(subject, data, { reply: sub.getSubject() });
       } catch (err) {
         cancel(err);
       }

tests/mrequest_test.ts

@@ -35,16 +35,20 @@ async function requestManyCount(noMux = false): Promise<void> {
   const { ns, nc } = await setup({});
   const nci = nc as NatsConnectionImpl;
 
+  let payload = "";
   const subj = createInbox();
   nc.subscribe(subj, {
     callback: (_err, msg) => {
+      if (payload === "") {
+        payload = msg.string();
+      }
       for (let i = 0; i < 5; i++) {
         msg.respond();
       }
     },
   });
 
-  const iter = await nci.requestMany(subj, Empty, {
+  const iter = await nci.requestMany(subj, "hello", {
     strategy: RequestStrategy.Count,
     maxWait: 2000,
     maxMessages: 5,
@@ -58,6 +62,7 @@ async function requestManyCount(noMux = false): Promise<void> {
   }
 
   assertEquals(nci.protocol.subscriptions.size(), noMux ? 1 : 2);
+  assertEquals(payload, "hello");
   assertEquals(iter.getProcessed(), 5);
   await cleanup(ns, nc);
 }