code: def subscribe(self, method, *params):
          '''
              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.
          '''
          assert '.' in method
          assert method.endswith('subscribe')
          return self._send_request(method, params, is_subscribe=Truef subscribe(self, method, *params):
          '''
              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.
          '''
          assert '.' in method
          assert method.endswith('subscribe')
          return self._send_request(method, params, is_subscribe=True)
docs: 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.