def __init__(self, async_session):
self._async_session = async_session<EOL>self._request_cb = self._notification_cb = None<EOL>self._pending_messages = deque()<EOL>self._is_running = False<EOL>self._setup_exception = None<EOL>self.loop = async_session.loop<EOL>self._loop_thread = None<EOL>
Wrap `async_session` on a synchronous msgpack-rpc interface.