def __init__(self, msgpack_stream):
self._msgpack_stream = msgpack_stream<EOL>self._next_request_id = <NUM_LIT:1><EOL>self._pending_requests = {}<EOL>self._request_cb = self._notification_cb = None<EOL>self._handlers = {<EOL><NUM_LIT:0>: self._on_request,<EOL><NUM_LIT:1>: self._on_response,<EOL><NUM_LIT:2>: self._on_notification<EOL>}<EOL>self.loop = msgpack_stream.loop<EOL>
Wrap `msgpack_stream` on a msgpack-rpc interface.