1 files changed, 5 insertions, 2 deletions
diff --git a/src/hero.mjs b/src/hero.mjs
index 699e426..bcc4fdb 100644
--- a/src/hero.mjs
+++ b/src/hero.mjs
@@ -363,7 +363,7 @@ export const makePipeReaderFn = ({
 	lineFn: lineHandler
 }) => path => {
 	mkfifo(path);
-	// TODO
+	fs.createReadStream(path, "UTF-8").on("data", makeLineEmitter(lineFn));
 };
 
 export const makePipeReader = makePipeReaderFn();
@@ -397,7 +397,10 @@ export const promisifyServer = (name, serverHandle, socket, pipe) => ({
 		rmIf(socket);
 		return serverHandle.listen(socket, ...args)
 	}),
-	close:  util.promisify((...args) => serverHandle.close(...args)),
+	close:  util.promisify((...args) => {
+		fs.createWriteStream(pipe).end();
+		return serverHandle.close(...args);
+	}),
 	events: serverHandle,
 });