|
15583 | 15583 | if (opts.priority === "event") { |
15584 | 15584 | this._sendNow(); |
15585 | 15585 | } else if (!this.sendIsEnqueued) { |
15586 | | - this.shinyapp.actionQueue.enqueue(function() { |
| 15586 | + this.shinyapp.taskQueue.enqueue(function() { |
15587 | 15587 | _this.sendIsEnqueued = false; |
15588 | 15588 | _this._sendNow(); |
15589 | 15589 | }); |
|
17666 | 17666 | function ShinyApp2() { |
17667 | 17667 | _classCallCheck36(this, ShinyApp2); |
17668 | 17668 | _defineProperty18(this, "$socket", null); |
17669 | | - _defineProperty18(this, "actionQueue", new AsyncQueue()); |
| 17669 | + _defineProperty18(this, "taskQueue", new AsyncQueue()); |
17670 | 17670 | _defineProperty18(this, "config", null); |
17671 | 17671 | _defineProperty18(this, "$inputValues", {}); |
17672 | 17672 | _defineProperty18(this, "$initialInput", null); |
|
17875 | 17875 | _this.startActionQueueLoop(); |
17876 | 17876 | }; |
17877 | 17877 | socket.onmessage = function(e) { |
17878 | | - _this.actionQueue.enqueue(/* @__PURE__ */ _asyncToGenerator8(/* @__PURE__ */ _regeneratorRuntime8().mark(function _callee2() { |
| 17878 | + _this.taskQueue.enqueue(/* @__PURE__ */ _asyncToGenerator8(/* @__PURE__ */ _regeneratorRuntime8().mark(function _callee2() { |
17879 | 17879 | return _regeneratorRuntime8().wrap(function _callee2$(_context2) { |
17880 | 17880 | while (1) |
17881 | 17881 | switch (_context2.prev = _context2.next) { |
|
17918 | 17918 | break; |
17919 | 17919 | } |
17920 | 17920 | _context3.next = 3; |
17921 | | - return this.actionQueue.dequeue(); |
| 17921 | + return this.taskQueue.dequeue(); |
17922 | 17922 | case 3: |
17923 | 17923 | action = _context3.sent; |
17924 | 17924 | _context3.prev = 4; |
|
0 commit comments