Function ReadableStreamClose

examples/io/streams/modules/streams.js:1348–1363

(stream)

	return then;
}
function ReadableStreamClose(stream) {
	const state = stream.state;	
	assert(state == "readable");
	stream.state = "closed";
	const reader = stream.reader;
	if (reader === undefined)
		return;
	resolvePromise(reader.closedPromise, undefined);
	if (ReadableStreamDefaultReaderBrand.has(reader.self)) {
		let readRequests = reader.readRequests;
		reader.readRequests = [];
		readRequests.forEach(readRequest => {
			readRequest.closeSteps();
		});
	}
}
function ReadableStreamError(stream, e) {
	const state = stream.state;	
	assert(state == "readable");