Function pullAlgorithm

examples/io/streams/modules/streams.js:1000–1053

()

	let branch2;
	let cancelPromise = createPromise();
	function pullAlgorithm() {
		if (reading) {
			readAgain = true;
			return Promise.resolve(undefined);
		}
		reading = true;
		const readRequest = {
			chunkSteps: chunk => {
				queueMicrotask(() => {
					readAgain = false;
					const chunk1 = chunk;
					const chunk2 = chunk;
					// if (canceled2 === false && cloneForBranch2 === true) {
					//	 try {
					//		 chunk2 = StructuredClone(chunk2);
					//	 }
					//	 catch (e) {
					//		 ReadableByteStreamControllerError(branch1.controller, e);
					//		 ReadableByteStreamControllerError(branch2.controller, e);
					//		 resolvePromise(cancelPromise, ReadableStreamCancel(stream, e));
					//		 return;
					//	 }
					// }
					if (canceled1 === false) {
						ReadableStreamDefaultControllerEnqueue(branch1.controller, chunk1);
					}
					if (canceled2 === false) {
						ReadableStreamDefaultControllerEnqueue(branch2.controller, chunk2);
					}
					reading = false;
					if (readAgain === true) {
						pullAlgorithm();
					}
				});
			},
			closeSteps: () => {
				reading = false;
				if (canceled1 === false) {
					ReadableStreamDefaultControllerClose(branch1.controller);
				}
				if (canceled2 === false) {
					ReadableStreamDefaultControllerClose(branch2.controller);
				}
				if (canceled1 === false || canceled2 === false) {
					resolvePromise(cancelPromise, undefined);
				}
			},
			errorSteps: () => {
				reading = false;
			}
		};
		ReadableStreamDefaultReaderRead(reader, readRequest);
		return Promise.resolve(undefined);
	}
	function cancel1Algorithm(reason) {
		canceled1 = true;
		reason1 = reason;