Function next

packages/core/src/common/stream.ts:530–539

()

	const reader = stream.getReader();
	return {
		async next() {
			try {
				const result = await reader.read();
				if (result?.done) reader.releaseLock(); // release lock when stream becomes closed
				return result;
			} catch (e) {
				reader.releaseLock(); // release lock when stream becomes errored
				throw e;
			}
		},
		async return() {
			const cancelPromise = reader.cancel();
			reader.releaseLock();