* Enqueue an operator into the priority queue for evaluation. The operator * will be enqueued if it has no registered pulse for the current cycle, or if * the force argument is true. Upon enqueue, this method also sets the * operator's qrank to the current rank value. * @param {Operator} op - Th
(op, force)
| 108564 | * enqueued during the current pulse propagation. This is useful when the |
| 108565 | * dataflow graph is dynamically modified and the operator rank changes. |
| 108566 | */ function enqueue(op, force) { |
| 108567 | const q = op.stamp < this._clock; |
| 108568 | if (q) op.stamp = this._clock; |
| 108569 | if (q || force) { |
| 108570 | op.qrank = op.rank; |
| 108571 | this._heap.push(op); |
| 108572 | } |
| 108573 | } |
| 108574 | /** |
| 108575 | * Provide a correct pulse for evaluating an operator. If the operator has an |
| 108576 | * explicit source operator, we will try to pull the pulse(s) from it. |
nothing calls this directly
no outgoing calls
no test coverage detected