From 9b85a6eac776ac3caca9180e3aa78d02470b8e47 Mon Sep 17 00:00:00 2001
From: "Eugeniy E. Mikhailov" <evgmik@gmail.com>
Date: Mon, 8 Feb 2021 17:59:23 -0500
Subject: flushing the stream

---
 lib/channels-lib.js | 1 +
 1 file changed, 1 insertion(+)

(limited to 'lib/channels-lib.js')

diff --git a/lib/channels-lib.js b/lib/channels-lib.js
index f2d8484..0d8193c 100644
--- a/lib/channels-lib.js
+++ b/lib/channels-lib.js
@@ -71,6 +71,7 @@ class StreamController {
 				this.streamData[datumIndex].oldestTimestampSeen = 0;
 			}
 			this.pushNewlySafeMessages();
+			this.outputStream.end()
 		}
 	}
 }
-- 
cgit v1.2.3