From ac469cdf4c70154a1c2cedce9edf5cdc3bdb2d61 Mon Sep 17 00:00:00 2001 From: Michael Denkowski Date: Mon, 19 Aug 2013 08:23:42 -0700 Subject: Realtime translation (mostly a cdec wrapper for now) --- realtime/rt/util.py | 13 +++++++++++++ 1 file changed, 13 insertions(+) create mode 100644 realtime/rt/util.py (limited to 'realtime/rt/util.py') diff --git a/realtime/rt/util.py b/realtime/rt/util.py new file mode 100644 index 00000000..7f877161 --- /dev/null +++ b/realtime/rt/util.py @@ -0,0 +1,13 @@ +import subprocess +import threading + +def popen_io(cmd): + p = subprocess.Popen(cmd, stdin=subprocess.PIPE, stdout=subprocess.PIPE, stderr=subprocess.PIPE) + consume_stream(p.stderr) + return p + +def consume_stream(stream): + def consume(s): + for _ in s: + pass + threading.Thread(target=consume, args=(stream,)).start() -- cgit v1.2.3