Flush hits when no activity from stdin

import_logs.py

@@ -39,6 +39,7 @@
 import os.path
 import queue
 import re
+import select
 import ssl
 import sys
 import threading
@@ -2506,6 +2507,13 @@ def filtered_line(line, reason):
         hits = []
         lineno = -1
         while True:
+            has_line = lambda f: select.select([f, ], [], [], 0.0)[0]
+            if os.name == 'posix' and file == sys.stdin and not has_line(file):
+                Recorder.add_hits(hits)
+                hits = []
+                time.sleep(1)
+                continue
+
             line = file.readline()
             if not line: break
             lineno = lineno + 1