diff --git a/src/socketio/async_pubsub_manager.py b/src/socketio/async_pubsub_manager.py
index 3e11f1e..72946eb 100644
--- a/src/socketio/async_pubsub_manager.py
+++ b/src/socketio/async_pubsub_manager.py
@@ -38,7 +38,7 @@ class AsyncPubSubManager(AsyncManager):
         self._get_logger().info(self.name + ' backend initialized.')
 
     async def emit(self, event, data, namespace=None, room=None, skip_sid=None,
-                   callback=None, **kwargs):
+                   callback=None, to=None, **kwargs):
         """Emit a message to a single client, a room, or all the clients
         connected to the namespace.
 
@@ -49,6 +49,7 @@ class AsyncPubSubManager(AsyncManager):
 
         Note: this method is a coroutine.
         """
+        room = to or room
         if kwargs.get('ignore_queue'):
             return await super().emit(
                 event, data, namespace=namespace, room=room, skip_sid=skip_sid,
diff --git a/tests/async/test_pubsub_manager.py b/tests/async/test_pubsub_manager.py
index 2881299..c7758fa 100644
--- a/tests/async/test_pubsub_manager.py
+++ b/tests/async/test_pubsub_manager.py
@@ -67,6 +67,23 @@ class TestAsyncPubSubManager(unittest.TestCase):
             }
         )
 
+    def test_emit_single_client(self):
+        sid = 'room-mate'
+        _run(self.pm.emit('foo', 'bar', to=sid))
+        self.pm._publish.mock.assert_called_once_with(
+            {
+                'method': 'emit',
+                'event': 'foo',
+                'data': 'bar',
+                'namespace': '/',
+                'room': sid,
+                'skip_sid': None,
+                'callback': None,
+                'host_id': '123456',
+            }
+        )
+
+
     def test_emit_with_namespace(self):
         _run(self.pm.emit('foo', 'bar', namespace='/baz'))
         self.pm._publish.mock.assert_called_once_with(