summaryrefslogtreecommitdiff
path: root/examples/subprocess_stream.py
diff options
context:
space:
mode:
Diffstat (limited to 'examples/subprocess_stream.py')
-rw-r--r--examples/subprocess_stream.py5
1 files changed, 2 insertions, 3 deletions
diff --git a/examples/subprocess_stream.py b/examples/subprocess_stream.py
index 1ece32d..c33cdc7 100644
--- a/examples/subprocess_stream.py
+++ b/examples/subprocess_stream.py
@@ -1,9 +1,8 @@
import asyncio
-from asyncio.base_subprocess import SubprocessStreamProtocol
@asyncio.coroutine
def cat(loop):
- transport, protocol = yield from loop.subprocess_shell(SubprocessStreamProtocol, "cat")
+ transport, protocol = yield from asyncio.subprocess_shell("cat")
print("pid: %s" % transport.get_pid())
stdin = protocol.stdin
stdout = protocol.stdout
@@ -20,7 +19,7 @@ def cat(loop):
@asyncio.coroutine
def ls(loop):
- transport, protocol = yield from loop.subprocess_shell(SubprocessStreamProtocol, "ls", stdin=None)
+ transport, protocol = yield from asyncio.subprocess_shell("ls", stdin=None)
while True:
line = yield from protocol.stdout.readline()
if not line: