()
| 71 | }; |
| 72 | }, |
| 73 | async close() { |
| 74 | if (aClosed) return; |
| 75 | aClosed = true; |
| 76 | // End the writer (signals end-of-stream to B's readable) |
| 77 | aWriter.endSync(); |
| 78 | // Stop iteration of this channel's readable |
| 79 | if (aReadableIterator?.return) { |
| 80 | await aReadableIterator.return(); |
| 81 | aReadableIterator = null; |
| 82 | } |
| 83 | }, |
| 84 | [SymbolAsyncDispose]() { |
| 85 | return this.close(); |
| 86 | }, |