diff -Nru a/trollius_redis/connection.py b/trollius_redis/connection.py
--- a/trollius_redis/connection.py	2015-04-21 00:47:33.000000000 +0200
+++ b/trollius_redis/connection.py	2019-01-12 04:11:50.641808907 +0100
@@ -59,7 +59,7 @@
         # Create protocol instance
         def connection_lost():
             if connection._auto_reconnect and not connection._closing:
-                asyncio.async(connection._reconnect(), loop=connection._loop)
+                asyncio.asynchronous(connection._reconnect(), loop=connection._loop)
 
         # Create protocol instance
         connection.protocol = protocol_class(
diff -Nru a/trollius_redis/protocol.py b/trollius_redis/protocol.py
--- a/trollius_redis/protocol.py	2015-04-21 00:51:43.000000000 +0200
+++ b/trollius_redis/protocol.py	2019-01-12 04:11:06.798527356 +0100
@@ -750,7 +750,7 @@
                         future2.set_result(result)
 
                     future.add_done_callback(
-                        lambda f: asyncio.async(
+                        lambda f: asyncio.asynchronous(
                             done(f.result()), loop=protocol_self._loop))
 
                     raise Return(future2)
@@ -934,7 +934,7 @@
         # Start parsing reader stream.
         self._reader = StreamReader(loop=self._loop)
         self._reader.set_transport(transport)
-        self._reader_f = asyncio.async(
+        self._reader_f = asyncio.asynchronous(
             self._reader_coroutine(), loop=self._loop)
 
         @asyncio.coroutine
@@ -958,7 +958,7 @@
                     yield From(self._psubscribe(
                         self._subscription, list(self._pubsub_patterns)))
 
-        asyncio.async(initialize(), loop=self._loop)
+        asyncio.asynchronous(initialize(), loop=self._loop)
 
     def data_received(self, data):
         """ Process data received from Redis server.  """
@@ -1114,7 +1114,7 @@
 
         # Return the empty queue immediately as an answer.
         if self._in_pubsub:
-            asyncio.async(
+            asyncio.asynchronous(
                 self._handle_pubsub_multibulk_reply(reply), loop=self._loop)
         else:
             cb(reply)
diff -Nru a/trollius_redis/replies.py b/trollius_redis/replies.py
--- a/trollius_redis/replies.py	2015-04-16 19:48:39.000000000 +0200
+++ b/trollius_redis/replies.py	2019-01-12 04:22:21.588881773 +0100
@@ -63,7 +63,7 @@
 
         for _ in range(self._result.count // 2):
             read_future = self._result._read(count=2)
-            yield asyncio.async(getter(read_future), loop=self._result._loop)
+            yield asyncio.asynchronous(getter(read_future), loop=self._result._loop)
 
     @asyncio.coroutine
     def asdict(self):