(
protected override upstream: LazyIterator<T>, protected windowSize: number,
seed?: string)
| 1146 | private upstreamExhausted = false; |
| 1147 | |
| 1148 | constructor( |
| 1149 | protected override upstream: LazyIterator<T>, protected windowSize: number, |
| 1150 | seed?: string) { |
| 1151 | super(upstream, windowSize); |
| 1152 | this.random = seedrandom.alea(seed || tf.util.now().toString()); |
| 1153 | this.lastRead = Promise.resolve({value: null, done: false}); |
| 1154 | } |
| 1155 | |
| 1156 | override async next(): Promise<IteratorResult<T>> { |
| 1157 | // This sets this.lastRead to a new Promise right away, as opposed to |