Function pipeStep

examples/io/streams/modules/streams.js:835–863

()

		}

		function pipeStep() {
			if (shuttingDown === true) {
				return Promise.resolve(true);
			}

			return writer.readyPromise.promise.then(() => {
				return new Promise((resolveRead, rejectRead) => {
					ReadableStreamDefaultReaderRead(
						reader,
						{
							chunkSteps: chunk => {
								currentWrite = createPromise();
								WritableStreamDefaultWriterWrite(writer,chunk).then(
									() => {
										resolvePromise(currentWrite, undefined);
									},
									(e) => { 
										resolvePromise(currentWrite, undefined);
									}
								);
								resolveRead(false);
							},
							closeSteps: () => resolveRead(true),
							errorSteps: rejectRead
						}
					);
				});
			});
		}

		// Errors must be propagated forward
		isOrBecomesErrored(source, reader.closedPromise.promise, storedError => {