Async iterator does not work with Duplex streams #33130

const {Duplex, PassThrough} = require('stream');

const response = new PassThrough();
setTimeout(() => response.write('chunk 1'), 500);
setTimeout(() => response.write('chunk 2'), 1000);
setTimeout(() => response.write('chunk 3'), 1500);
setTimeout(() => response.end(), 2000);

class HelloWorld extends Duplex {
	constructor(response) {
		super();

		this.response = response;
		this.readMore = false;

		response.once('end', () => {
			this.push(null);
		});

		response.on('readable', () => {
			if (this.readMore) {
				this._read();
			}
		});
	}

	_read() {
		const {response} = this;

		this.readMore = true;

		if (response.readableLength) {
			this.readMore = false;
		}

		let data;
		while ((data = response.read()) !== null) {
			this.push(data);
		}
	}
}

const instance = new HelloWorld(response);
instance.end();

(async () => {
	await new Promise(resolve => setTimeout(resolve, 100));

	for await (const data of instance) {
		console.log(data.toString());
	}

	console.log('finished await');
})();