feat: bumping sizes to be consistent with actionlib

6RiverSystems · Feb 8, 2021 · 13d15b5 · 13d15b5
1 parent 56c0c6a
commit 13d15b5
Showing 1 changed file with 5 additions and 5 deletions.
diff --git a/src/lib/ActionClientInterface.js b/src/lib/ActionClientInterface.js
@@ -41,29 +41,29 @@ class ActionClientInterface extends EventEmitter {
 
     const nh = options.nh;
 
-    const goalOptions = Object.assign({ queueSize: 10, latching: true }, options.goal);
+    const goalOptions = Object.assign({ queueSize: 50, latching: true }, options.goal);
     this._goalPub = nh.advertise(this._actionServer + '/goal',
                                  this._actionType + 'Goal',
                                  goalOptions);
 
-    const cancelOptions = Object.assign({ queueSize: 10, latching: true }, options.cancel);
+    const cancelOptions = Object.assign({ queueSize: 50, latching: true }, options.cancel);
     this._cancelPub = nh.advertise(this._actionServer + '/cancel',
                                    'actionlib_msgs/GoalID',
                                    cancelOptions);
 
-    const statusOptions = Object.assign({ queueSize: 25 }, options.status);
+    const statusOptions = Object.assign({ queueSize: 50 }, options.status);
     this._statusSub = nh.subscribe(this._actionServer + '/status',
                                    'actionlib_msgs/GoalStatusArray',
                                    (msg) => { this._handleStatus(msg); },
                                    statusOptions);
 
-    const feedbackOptions = Object.assign({ queueSize: 25 }, options.feedback);
+    const feedbackOptions = Object.assign({ queueSize: 50 }, options.feedback);
     this._feedbackSub = nh.subscribe(this._actionServer + '/feedback',
                                      this._actionType + 'Feedback',
                                      (msg) => { this._handleFeedback(msg); },
                                      feedbackOptions);
 
-    const resultOptions = Object.assign({ queueSize: 25 }, options.result);
+    const resultOptions = Object.assign({ queueSize: 50 }, options.result);
     this._resultSub = nh.subscribe(this._actionServer + '/result',
                                    this._actionType + 'Result',
                                    (msg) => { this._handleResult(msg); },