`agent.request()` is unsafe about http2-wrapper HOT 4 CLOSED

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

const think = () => new Promise((resolve, reject) => {
	const p = new PassThrough();
    process.nextTick(() => p.destroy(new Error('no way')));
    resolve(p);
});

(async () => {
	const stream = await think();

	stream.once('error', () => {
		console.log('Caught stream error');
	});
})();

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

const think = () => new Promise((resolve, reject) => {
	const p = new PassThrough();
    p.__destroy = p._destroy;
    p._destroy = async (...args) => {
        const callback = args.pop();
        
        const next = Promise.resolve();
        p.__destroy(...args, async error => {
            await next;
            callback(error);
        });
    };
    
    process.nextTick(() => p.destroy(new Error('no way')));
    resolve(p);
});

(async () => {
	const stream = await think();

	stream.once('error', () => {
		console.log('Caught stream error');
	});
})();

const {connect} = require('http2');
const {TLSSocket} = require('tls');

const think = () => new Promise((resolve, reject) => {
	const session = connect('https://httpbin.org', {
        createConnection: (...args) => {
            const socket = new TLSSocket();
            process.nextTick(() => socket.destroy(new Error('oh no')));
            return socket;
        }
    });

    // session.once('error', () => {
    //     console.log('Error caught before await');
    // });

    resolve(session);
});

(async () => {
	const session = await think();

	session.once('error', () => {
		console.log('Caught session error');
	});
})();

const {connect} = require('http2');
const {TLSSocket} = require('tls');

const think = () => new Promise(async (resolve, reject) => {
	const session = connect('https://httpbin.org', {
        createConnection: (...args) => {
            const socket = new TLSSocket();
            process.nextTick(() => socket.destroy(new Error('oh no')));
            return socket;
        }
    });

    const promise = Promise.resolve();
    const onError = async error => {
        await promise;

        session.emit('error', error);
    };

    session.once('error', onError);
    resolve(session);
    
    await promise;
    session.off('error', onError);
});

(async () => {
	const session = await think();

	session.once('error', () => {
		console.log('Caught session error');
	});
})();