Function CreateReadableStream

examples/io/streams/modules/streams.js:737–746

(startAlgorithm, pullAlgorithm, cancelAlgorithm, highWaterMark = 1, sizeAlgorithm = () => 1)

const defaultSizeAlgorithm = function() { return 1 }

function CreateReadableStream(startAlgorithm, pullAlgorithm, cancelAlgorithm, highWaterMark = 1, sizeAlgorithm = () => 1) {
	assert(IsNonNegativeNumber(highWaterMark) === true);
	const stream = new ReadableStream(ReadableStreamBrand.token);
	InitializeReadableStream(stream);
	const controller = new ReadableStreamDefaultController(ReadableStreamDefaultControllerBrand.token);
	SetUpReadableStreamDefaultController(
		stream, controller, startAlgorithm, pullAlgorithm, cancelAlgorithm, highWaterMark, sizeAlgorithm
	);
	return stream;
}
function CreateReadableByteStream(startAlgorithm, pullAlgorithm, cancelAlgorithm) {
	const stream = new ReadableStream(ReadableStreamBrand.token);
	InitializeReadableStream(stream);