[ADDED] kvStore_WatchMulti, js_Subscribe[Sync]Multi

src/js.c

@@ -2224,8 +2224,8 @@
     }
     if ((numSubjects == 1) && nats_IsStringEmpty(subjects[0]))
     {
         subjects = NULL;
         numSubjects = 0;
     }
 
     // Match the subjects against the consumer's filter subjects.
@@ -2603,7 +2603,7 @@
                 int l = nats_printStringArray(NULL, 0, subjects, numSubjects);
                 jsi->psubj = NATS_CALLOC(l, 1); // '\0' included
                 if (jsi->psubj == NULL)
                     s = nats_setDefaultError(NATS_NO_MEMORY);
                 if (s == NATS_OK)
                     nats_printStringArray(jsi->psubj, l, subjects, numSubjects);
             }
@@ -2764,12 +2764,12 @@
            natsMsgHandler usrCB, void *usrCBClosure, bool isPullMode,
            jsOptions *jsOpts, jsSubOptions *opts, jsErrCode *errCode)
 {
+    natsStatus s = NATS_OK;
     const char *subjects[] = {subject};
+    int numSubjects = nats_IsStringEmpty(subject) ? 0 : 1;
 
-    if (nats_IsStringEmpty(subject))
-        return _subscribeMulti(new_sub, js, NULL, 0, pullDurable, usrCB, usrCBClosure, isPullMode, jsOpts, opts, errCode);
-
-    return _subscribeMulti(new_sub, js, subjects, 1, pullDurable, usrCB, usrCBClosure, isPullMode, jsOpts, opts, errCode);
+    s = _subscribeMulti(new_sub, js, subjects, numSubjects, pullDurable, usrCB, usrCBClosure, isPullMode, jsOpts, opts, errCode);
+    return NATS_UPDATE_ERR_STACK(s);
 }
 
 natsStatus
@@ -2790,20 +2790,20 @@
 }
 
 natsStatus
 js_SubscribeMulti(natsSubscription **sub, jsCtx *js, const char **subjects, int numSubjects,
                   natsMsgHandler cb, void *cbClosure,
                   jsOptions *jsOpts, jsSubOptions *opts, jsErrCode *errCode)
 {
     natsStatus s;
 
     if (errCode != NULL)
         *errCode = 0;
 
     if (cb == NULL)
         return nats_setDefaultError(NATS_INVALID_ARG);
 
     s = _subscribeMulti(sub, js, subjects, numSubjects, NULL, cb, cbClosure, false, jsOpts, opts, errCode);
     return NATS_UPDATE_ERR_STACK(s);
 }
 
 natsStatus
@@ -2829,7 +2829,7 @@
         *errCode = 0;
 
     s = _subscribeMulti(sub, js, subjects, numSubjects, NULL, NULL, NULL, false, jsOpts, opts, errCode);
     return NATS_UPDATE_ERR_STACK(s);
 }
 
 natsStatus