Initial commit.

demo/stderr.py

+import os
+
+import pcl_expect.spawn
+import pcl_expect.user
+import pcl_expect
+
+pcl_expect.spawn.stty_init = "-onlcr -ocrnl"
+
+sh, sh_err = pcl_expect.spawn.spawn2(os.getenv("SHELL"))
+user = pcl_expect.user.User(pcl_expect.user.CBREAK)
+
+x = pcl_expect.Controller()
+while x.loop():
+    if x.re(user, "(?s)..*"):
+        sh.send(user.consumed)
+    elif x.re(sh_err, "(?s)..*"):
+        # user.send("STDERR: ``%s''.\n" % repr(sh_err.consumed))
+        user.send(sh_err.consumed)
+    elif x.re(sh, "(?s)..*"):
+        # user.send("STDOUT: ``%s''.\n" % repr(sh.consumed))
+        user.send(sh.consumed)
+    elif x.timeout():
+        pass
+    elif x.eof(user):
+        break
+    elif x.eof(sh_err):
+        break
+    elif x.eof(sh):
+        break
+
+sh.close()

demo/stdout.py

+import os
+
+import pcl_expect.spawn
+import pcl_expect.user
+import pcl_expect
+
+pcl_expect.spawn.stty_init = "-onlcr -ocrnl"
+
+sh = pcl_expect.spawn.Spawn(os.getenv("SHELL"))
+user = pcl_expect.user.User(pcl_expect.user.CBREAK)
+
+x = pcl_expect.Controller()
+while x.loop():
+    if x.re(user, "(?s)..*"):
+        sh.send(user.consumed)
+    elif x.re(sh, "(?s)..*"):
+        # user.send("STDOUT: ``%s''.\n" % repr(sh.consumed))
+        user.send(sh.consumed)
+    elif x.timeout():
+        pass
+    elif x.eof(user):
+        break
+    elif x.eof(sh):
+        break
+
+sh.close()