Function pipeLoop

examples/io/streams/modules/streams.js:821–833

()

		// - Backpressure must be enforced
		// - Shutdown must stop all activity
		function pipeLoop() {
			return new Promise((resolveLoop, rejectLoop) => {
				function next(done) {
					if (done) {
						resolveLoop();
					} else {
						pipeStep().then(next, rejectLoop);
					}
				}

				next(false);
			});
		}

		function pipeStep() {
			if (shuttingDown === true) {