* @param {EventSourceStreamEvent} event
(event)
| 18872 | } |
| 18873 | if (this.buffer[this.pos] === LF || this.buffer[this.pos] === CR) { |
| 18874 | if (this.buffer[this.pos] === CR) { |
| 18875 | this.crlfCheck = true; |
| 18876 | } |
| 18877 | this.buffer = this.buffer.subarray(this.pos + 1); |
| 18878 | this.pos = 0; |
| 18879 | if (this.event.data !== void 0 || this.event.event || this.event.id || this.event.retry) { |
| 18880 | this.processEvent(this.event); |
| 18881 | } |
| 18882 | this.clearEvent(); |
| 18883 | continue; |
| 18884 | } |
| 18885 | this.eventEndCheck = false; |
| 18886 | continue; |
| 18887 | } |
| 18888 | if (this.buffer[this.pos] === LF || this.buffer[this.pos] === CR) { |
| 18889 | if (this.buffer[this.pos] === CR) { |
| 18890 | this.crlfCheck = true; |
| 18891 | } |
| 18892 | this.parseLine(this.buffer.subarray(0, this.pos), this.event); |
| 18893 | this.buffer = this.buffer.subarray(this.pos + 1); |
| 18894 | this.pos = 0; |
no test coverage detected