node.jsでStreamを使用したプログラムが終了しない

Question

前提・実現したいこと

OS:Linux
言語:node.js

上記環境でmkfifoコマンドにより作成した名前付きパイプに書き込んだ文字列を
指定の端末およびログファイルにリダイレクトするプログラムを作成したいと思っています。

発生している問題・エラーメッセージ

端末およびログファイルへのリダイレクトは上手くいくのですが
プログラムが終了せず、Ctrl+Cで強制終了するしかない状態です。
プログラムを正常終了させる方法を教えていただけないでしょうか。

該当のソースコード

const fs = require('fs');
const stream = require('stream');

const PIPE = 'mkfifoで作成した名前付パイプのパス';
const TTY  = 'ttyコマンドで取得したパス';
const LOG  = 'ログファイルのパス';

async function wait(msec) {
	return new Promise((resolve, reject) => setTimeout(() => resolve(), msec));
}

!async function main() {
	// パイプ書込／読込ストリーム
	const writer = fs.createWriteStream(null, {fd:fs.openSync(PIPE, 'w+')});
	const reader = fs.createReadStream (null, {fd:fs.openSync(PIPE, 'r+')});
	// 端末書込ストリーム
	const tty = fs.createWriteStream(null, {fd:fs.openSync(TTY, 'w')});
	// ログ書込ストリーム
	const log = fs.createWriteStream(null, {fd:fs.openSync(LOG, 'a')});
	// ストリーム分岐用
	const hub   = new stream.PassThrough();
	const wire1 = new stream.PassThrough();
	const wire2 = new stream.PassThrough();
	
	// ストリームを以下のように接続
	//   reader ---> hub ---> wire1 ---> tty
	//                   ---> wire2 ---> log
	reader.pipe(hub);
	hub.pipe(wire1).pipe(tty);
	hub.pipe(wire2).pipe(log);
	
	// パイプに書き込み
	writer.write('hello\n');
	
	// 1秒待機
	await wait(1_000);
	
	// 終了処理
	console.log('----- EXIT -----');
	
	reader.push(null);
	reader.read(0);
	
	writer.end();
	writer.close();
	
	tty.end();
	tty.close();
	
	log.end();
	log.close();
}();

試したこと

• main()の末尾でprocess.exit()を実行してもプログラムが終了しませんでした。
• await wait(1_000);をコメントアウトすると、プログラムは終了するのですがリダイレクトされませんでした。

Answer 1

端末およびログファイルへのリダイレクトは上手くいくのですが

(中略)
プログラムを正常終了させる方法

Promise を使った wait() 関数の引数（msec）は {number} のはずです。
1_000 を与えているので、エラーとなり、 reject() されていないのでは？

async function wait(msec) {
  return new Promise((resolve, reject) => {
    try {
      setTimeout(() => resolve(), msec));
    } catch( e ) {
      reject(e)
    }
}

試しに、1_000 を与えて setTimeout を実行した例

setTimeout(() => {
  console.log("test timeout")
}, 1_000);
// => Uncaught SyntaxError: Invalid or unexpected token

Comments

[saoka]

回答ありがとうございます。
数値中のアンダースコアはnumeric separatorという機能で
まだ正式採用されていないのかもしれませんが
私の環境では 1_000 は number として認識されているので大丈夫だと思います

$ node --version
v14.9.0
$ node -e 'console.log(typeof 1_000)'
number

[AkitoshiManabe]

> numeric separatorという機能
これは、勉強になりました。ありがとうございます。

ご質問のコードは試していないのですが、Stream 関連のドキュメントを読んで感じた２点：
1. fs.createReadStream() / fs.createWriteStream() は第一引数に PATH を与え、read/writeのバッファに直接作用させても良いのではないか？（オプションでfh のフラグを指定）
2. コールバック方式で利用し、 Promise 化を考える（ stream.end() や stream.close() は処理を強制するので 1秒で終わらない長いストリームは、異常終了しないかと感じました）。
async await を使うとコードは短くて見通しが良さそうになりますが、公開される各モジュールは旧バージョンへの対応もあってか、「泥臭い方法」が多いようです。
解決に至る回答はできませんでしたが、参考になればと思います。

[saoka]

さらなる回答ありがとうございます。
ご指摘いただいた方法でも試してみようと思います。