diff --git a/wpull/driver/process.py b/wpull/driver/process.py
index e370538e..94f7f7c5 100644
--- a/wpull/driver/process.py
+++ b/wpull/driver/process.py
@@ -53,8 +53,9 @@ def start(self, use_atexit=True):
         )
         self._process = yield from process_future
 
-        self._stderr_reader = asyncio.async(self._read_stderr())
-        self._stdout_reader = asyncio.async(self._read_stdout())
+        _async=getattr(asyncio, 'async')
+        self._stderr_reader = _async(self._read_stderr())
+        self._stdout_reader = _async(self._read_stdout())
 
         if use_atexit:
             atexit.register(self.close)