Method toReadableStream

packages/core/src/common/stream.ts:180–205

* Converts this stream to a newline-separated ReadableStream of * JSON stringified values in the stream which can be turned back into a Stream with `Stream.fromReadableStream()`.

()

	 * JSON stringified values in the stream which can be turned back into a Stream with `Stream.fromReadableStream()`.
	 */
	toReadableStream(): ReadableStream {
		const self = this;
		let iter: AsyncIterator<Item>;
		const encoder = new TextEncoder();

		return new ReadableStream({
			async start() {
				iter = self[Symbol.asyncIterator]();
			},
			async pull(ctrl: any) {
				try {
					const {value, done} = await iter.next();
					if (done) return ctrl.close();

					const bytes = encoder.encode(JSON.stringify(value) + '\n');

					ctrl.enqueue(bytes);
				} catch (err) {
					ctrl.error(err);
				}
			},
			async cancel() {
				await iter.return?.();
			},
		});
	}
}

/**