(op: CmapOperation, thread?: Thread)
| 131 | } |
| 132 | |
| 133 | queue(op: CmapOperation, thread?: Thread) { |
| 134 | if (this.#killed || this.#error) { |
| 135 | return; |
| 136 | } |
| 137 | |
| 138 | const functionToQueue = () => (!thread ? this._runOperation(op) : thread.queue(op)); |
| 139 | |
| 140 | this.#promise = this.#promise.then(functionToQueue).catch(e => (this.#error = e)); |
| 141 | } |
| 142 | |
| 143 | async finish() { |
| 144 | this.#killed = true; |
no outgoing calls
no test coverage detected