(ctrl)
| 69205 | toReadableStream() { |
| 69206 | const self2 = this; |
| 69207 | let iter; |
| 69208 | const encoder = new TextEncoder(); |
| 69209 | return new ReadableStream2({ |
| 69210 | async start() { |
| 69211 | iter = self2[Symbol.asyncIterator](); |
| 69212 | }, |
| 69213 | async pull(ctrl) { |
| 69214 | try { |
| 69215 | const { value, done } = await iter.next(); |
| 69216 | if (done) |
| 69217 | return ctrl.close(); |
| 69218 | const bytes = encoder.encode(JSON.stringify(value) + "\n"); |
| 69219 | ctrl.enqueue(bytes); |
| 69220 | } catch (err) { |