talking to a subprocess

thomasballinger · thomasballinger · commit 4c6b2430f015 · 2014-07-30T11:35:33.000-04:00
diff --git a/bpython/curtsies.py b/bpython/curtsies.py
@@ -3,6 +3,8 @@
 import sys
 import code
 import logging
+import select
+from subprocess import Popen, PIPE
 from optparse import Option
 from itertools import izip
 
@@ -71,6 +73,8 @@ def mainloop(config, locals_, banner, interp=None, paste=None, interactive=True)
                 hide_cursor=False,
                 extra_bytes_callback=input_generator.unget_bytes) as window:
 
+            p = Popen(['python', '-m', 'bpython.curtsiesfrontend.beeper'], stdout=PIPE)
+
             refresh_requests = []
             def request_refresh():
                 refresh_requests.append(curtsies.events.RefreshRequestEvent())
@@ -79,7 +83,18 @@ def event_or_refresh(timeout=None):
                     if refresh_requests:
                         yield refresh_requests.pop()
                     else:
-                        yield input_generator.send(timeout)
+                        try:
+                            rs, ws, es = select.select([input_generator, p.stdout], [], [])
+                        except select.error as e:
+                            print e
+                            yield curtsies.events.SigIntEvent()
+                        else:
+                            for r in rs:
+                                if r is input_generator:
+                                    yield input_generator.send(timeout)
+                                else:
+                                    p.stdout.readline()
+                                    yield u'a'
 
             global repl # global for easy introspection `from bpython.curtsies import repl`
             with Repl(config=config,
diff --git a/bpython/curtsiesfrontend/beeper.py b/bpython/curtsiesfrontend/beeper.py
@@ -0,0 +1,9 @@
+import time
+import sys
+
+if __name__ == '__main__':
+    while True:
+        sys.stdout.write('beep\n')
+        sys.stdout.flush()
+        time.sleep(5)
+
