()
| 834 | protected outputQueue: RingBuffer<T>; |
| 835 | |
| 836 | constructor() { |
| 837 | super(); |
| 838 | this.outputQueue = new GrowingRingBuffer<T>(); |
| 839 | this.lastRead = Promise.resolve({value: null, done: false}); |
| 840 | } |
| 841 | |
| 842 | async next(): Promise<IteratorResult<T>> { |
| 843 | // This sets this.lastRead to a new Promise right away, as opposed to |
nothing calls this directly
no outgoing calls
no test coverage detected
searching dependent graphs…