* @param {Buffer} line * @param {EventStreamEvent} event
(line, event)
| 18822 | } |
| 18823 | } |
| 18824 | return true; |
| 18825 | } |
| 18826 | var EventSourceStream = class extends Transform { |
| 18827 | /** |
| 18828 | * @param {object} options |
| 18829 | * @param {eventSourceSettings} options.eventSourceSettings |
| 18830 | * @param {Function} [options.push] |
| 18831 | */ |
| 18832 | constructor(options = {}) { |
| 18833 | options.readableObjectMode = true; |
| 18834 | super(options); |
| 18835 | /** |
| 18836 | * @type {eventSourceSettings} |
| 18837 | */ |
| 18838 | __publicField(this, "state", null); |
| 18839 | /** |
| 18840 | * Leading byte-order-mark check. |
| 18841 | * @type {boolean} |
| 18842 | */ |
| 18843 | __publicField(this, "checkBOM", true); |
| 18844 | /** |
| 18845 | * @type {boolean} |
| 18846 | */ |
| 18847 | __publicField(this, "crlfCheck", false); |
| 18848 | /** |
| 18849 | * @type {boolean} |
| 18850 | */ |
| 18851 | __publicField(this, "eventEndCheck", false); |
| 18852 | /** |
| 18853 | * @type {Buffer[]} |
| 18854 | */ |
| 18855 | __publicField(this, "chunks", []); |
| 18856 | __publicField(this, "chunkIndex", 0); |
| 18857 | __publicField(this, "pos", 0); |
| 18858 | __publicField(this, "lineChunkIndex", 0); |
| 18859 | __publicField(this, "linePos", 0); |
| 18860 | __publicField(this, "event", { |
| 18861 | data: void 0, |
| 18862 | event: void 0, |
| 18863 | id: void 0, |
| 18864 | retry: void 0 |
| 18865 | }); |
| 18866 | this.state = options.eventSourceSettings || {}; |
| 18867 | if (options.push) { |
| 18868 | this.push = options.push; |
| 18869 | } |
| 18870 | } |
| 18871 | /** |
| 18872 | * @param {Buffer} chunk |
| 18873 | * @param {string} _encoding |
no test coverage detected