(iterator2, cancel)
| 77963 | function makeAsyncIterable2(webStream) { |
| 77964 | if (!webStream[Symbol.asyncIterator]) { |
| 77965 | webStream[Symbol.asyncIterator] = () => toAsyncIterable(webStream); |
| 77966 | } |
| 77967 | if (!webStream.values) { |
| 77968 | webStream.values = () => toAsyncIterable(webStream); |
| 77969 | } |
| 77970 | } |
| 77971 | function iteratorToStream(iterator2, cancel) { |
| 77972 | return new ReadableStream({ |
| 77973 | async pull(controller) { |
| 77974 | const { value, done } = await iterator2.next(); |
| 77975 | if (done) { |
| 77976 | controller.close(); |
| 77977 | } else { |
| 77978 | controller.enqueue(value); |
| 77979 | } |
| 77980 | }, |
no outgoing calls
no test coverage detected
searching dependent graphs…