homepage

The following uses socketpair() instead of pipe() for stdin, and works for me on Linux:
diff -r 7d94e4a68b91 asyncio/unix_events.py
--- a/asyncio/unix_events.py Sun Oct 20 20:25:04 2013 -0700
+++ b/asyncio/unix_events.py Mon Oct 21 17:15:19 2013 +0100
@@ -272,8 +272,6 @@
 self._loop = loop
 self._pipe = pipe
 self._fileno = pipe.fileno()
- if not stat.S_ISFIFO(os.fstat(self._fileno).st_mode):
- raise ValueError("Pipe transport is for pipes only.")
 _set_nonblocking(self._fileno)
 self._protocol = protocol
 self._buffer = []
@@ -442,9 +440,16 @@
 self._finished = False
 self._returncode = None
+ if stdin == subprocess.PIPE:
+ stdin_w, stdin_r = socket.socketpair()
+ else:
+ stdin_w = stdin_r = None
 self._proc = subprocess.Popen(
- args, shell=shell, stdin=stdin, stdout=stdout, stderr=stderr,
+ args, shell=shell, stdin=stdin_r, stdout=stdout, stderr=stderr,
 universal_newlines=False, bufsize=bufsize, **kwargs)
+ if stdin_r is not None:
+ stdin_r.close()
+ self._proc.stdin = open(stdin_w.detach(), 'rb', buffering=bufsize)
 self._extra['subprocess'] = self._proc
 def close(self):