[ADDED] JetStream: natsSubscription_FetchRequest

Similar to natsSubscription_Fetch but allows user to fully configure the fetch request. Signed-off-by: Ivan Kozlovic <ivan@synadia.com>
nats-io · Sep 19, 2022 · 2cd5ee1 · 2cd5ee1
1 parent 5b8f3aa
commit 2cd5ee1
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)