MCPcopy Create free account
hub / github.com/angular/dev-infra / parseLine

Method parseLine

github-actions/bazel/configure-remote/configure-remote.js:18824–18870  ·  view source on GitHub ↗

* @param {Buffer} line * @param {EventStreamEvent} event

(line, event)

Source from the content-addressed store, hash-verified

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

Callers 1

_transformMethod · 0.45

Calls 3

isASCIINumberFunction · 0.70
isValidLastEventIdFunction · 0.70
toStringMethod · 0.45

Tested by

no test coverage detected