Merge pull request #584 from nats-io/js_add_fetch_request

[ADDED] JetStream: natsSubscription_FetchRequest
nats-io · Sep 19, 2022 · 157ce3a · 157ce3a
2 parents 5b8f3aa + 2cd5ee1
commit 157ce3a
Show file tree

Hide file tree

Showing 9 changed files with 483 additions and 110 deletions.
diff --git a/src/conn.c b/src/conn.c
@@ -2663,7 +2663,9 @@ natsConn_processMsg(natsConnection *nc, char *buf, int bufLen)
         return NATS_OK;
     }
 
-    if ((jsi = sub->jsi) != NULL)
+    jsi = sub->jsi;
+    // For JS subscriptions (but not pull ones), handle hearbeat and flow control here.
+    if (jsi && !jsi->pull)
     {
         ctrlMsg = natsMsg_isJSCtrl(msg, &jct);
         if (ctrlMsg && jct == jsCtrlHeartbeat)