Method pull

packages/core/src/common/stream.ts:189–200

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