(opPromise)
| 16 | } |
| 17 | |
| 18 | run(opPromise) { |
| 19 | if (this._killed || this._error) { |
| 20 | throw new Error('Attempted to run operation on killed thread'); |
| 21 | } |
| 22 | |
| 23 | this._promise = this._promise.then(() => opPromise).catch(e => (this._error = e)); |
| 24 | } |
| 25 | |
| 26 | finish() { |
| 27 | this._killed = true; |
no outgoing calls
no test coverage detected