()
| 70409 | if (!__classPrivateFieldGet7(this, _MessageStream_catchingPromiseCreated, "f") && !listeners?.length) { |
| 70410 | Promise.reject(error); |
| 70411 | } |
| 70412 | __classPrivateFieldGet7(this, _MessageStream_rejectConnectedPromise, "f").call(this, error); |
| 70413 | __classPrivateFieldGet7(this, _MessageStream_rejectEndPromise, "f").call(this, error); |
| 70414 | this._emit("end"); |
| 70415 | } |
| 70416 | } |
| 70417 | _emitFinal() { |
| 70418 | const finalMessage = this.receivedMessages.at(-1); |
| 70419 | if (finalMessage) { |
no test coverage detected