无有效数据时如何向Node.js流发送end事件解决wof-admin-lookup挂起问题

该问题本质是wof-admin-lookup依赖的parallel-transform流在未接收任何有效数据的场景下，绑定的end事件回调未正常触发，导致createPipResolverEnd返回的资源清理逻辑没有执行，pipResolver内部残留的打开句柄、定时器等异步资源一直存活，阻塞了Node.js进程的自然退出。
你观测到下游流触发finish事件打印导入计数，说明整个管道的数据流已经正常结束，仅遗漏了adminLookup模块的资源清理逻辑执行。

1. 业务代码快速修复（无需修改依赖包） #

在流的finish回调中主动触发资源清理，适合单次批量导入脚本场景：

stream
  .on('data', data => {
      count++
  })
  .on('finish', () => {
      console.log(`Imported ${count} addresses`)
      // 主动触发adminLookup的资源清理事件
      adminLookupStream.emit('end')
      resolve()
  })
  .on('error', (e) => {
      reject(e)
  })

*注意需要提前保存adminLookup流的实例：const adminLookupStream = adminLookup.create()，再将其插入管道中。

如果是纯离线批量导入脚本，也可以直接在finish回调中安全退出进程：

.on('finish', () => {
  console.log(`Imported ${count} addresses`)
  process.exit(0)
})

2. 依赖包层面永久修复 #

修改wof-admin-lookup的核心导出逻辑，给parallel-transform流增加自动销毁配置，同时监听close事件兜底执行资源清理：

module.exports = function(pipResolver, config) {
  if (!pipResolver) {
    throw new Error('valid pipResolver required to be passed in as the first parameter');
  }

  config = config || {};

  const pipResolverStream = createPipResolverStream(pipResolver, config);
  const end = createPipResolverEnd(pipResolver);

  // 新增autoDestroy配置，确保流结束后自动销毁
  const stream = parallelTransform({
    maxConcurrency: config.maxConcurrentReqs || 1,
    autoDestroy: true
  }, pipResolverStream);
  // 同时监听end和close事件，兜底执行清理
  stream.on('end', end);
  stream.on('close', end);

  return stream;
};

修改后无论有没有数据流经流，资源清理逻辑都会正常执行，进程会自动退出。

内容的提问来源于stack exchange，提问作者Nguyen Hoang Vu