Method pull

packages/baseai/src/dev/utils/stream/stream.ts:197–208

(ctrl: any)

				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?.();
			}