926162a2eaCorrect the implementaton of enabledHooksExist to return true if there are enabled hooks. Adapt callsites which used getHooksArrays() as workaround. PR-URL: https://github.com/nodejs/node/pull/61054 Fixes: https://github.com/nodejs/node/issues/61019 Refs: https://github.com/nodejs/node/pull/59873 Reviewed-By: Matteo Collina <matteo.collina@gmail.com> Reviewed-By: Gürgün Dayıoğlu <hey@gurgun.day>
34 lines
1,004 B
JavaScript
34 lines
1,004 B
JavaScript
// Flags: --expose-internals
|
|
'use strict';
|
|
|
|
const common = require('../common');
|
|
const { Readable, finished } = require('stream');
|
|
const { createHook, executionAsyncId } = require('async_hooks');
|
|
const assert = require('assert');
|
|
const { enabledHooksExist } = require('internal/async_hooks');
|
|
|
|
// This test verifies that when there are active async hooks, stream.finished() uses
|
|
// the bindAsyncResource path
|
|
|
|
createHook({
|
|
init(asyncId, type, triggerAsyncId) {
|
|
if (type === 'STREAM_END_OF_STREAM') {
|
|
const parentContext = contextMap.get(triggerAsyncId);
|
|
contextMap.set(asyncId, parentContext);
|
|
}
|
|
}
|
|
}).enable();
|
|
|
|
const contextMap = new Map();
|
|
const asyncId = executionAsyncId();
|
|
contextMap.set(asyncId, 'abc-123');
|
|
const readable = new Readable();
|
|
|
|
finished(readable, common.mustCall(() => {
|
|
const currentAsyncId = executionAsyncId();
|
|
const ctx = contextMap.get(currentAsyncId);
|
|
assert.ok(enabledHooksExist());
|
|
assert.strictEqual(ctx, 'abc-123');
|
|
}));
|
|
|
|
readable.destroy();
|