def subscribe(self, method, *params):
assert '<STR_LIT:.>' in method<EOL>assert method.endswith('<STR_LIT>')<EOL>return self._send_request(method, params, is_subscribe=True)<EOL>
Perform a remote command which will stream events/data to us.

Expects a method name, which look like:
    server.peers.subscribe
.. and sometimes take arguments, all of which are positional.

Returns a tuple: (Future, asyncio.Queue).
The future will have the result of the initial
call, and the queue will receive additional
responses as they happen.