(packet)
| 8651 | } |
| 8652 | |
| 8653 | write(packet) { |
| 8654 | if (this._timeoutId !== undefined) { |
| 8655 | clearTimeout(this._timeoutId); |
| 8656 | delete this._timeoutId; |
| 8657 | } |
| 8658 | this.applyBackpressure(packet); |
| 8659 | if (this._resolve) { |
| 8660 | this._resolve(); |
| 8661 | delete this._resolve; |
| 8662 | } |
| 8663 | } |
| 8664 | |
| 8665 | kill(value) { |
| 8666 | if (this._timeoutId !== undefined) { |
no test coverage detected