code: func (c *Client) RPC(method string, args interface{}, resp interface{}) error {
  	// Get a stream
  	stream, err := c.Open()
  	if err != nil {
  		return fmt.Errorf("failed to open stream: %v", err)
  	}
  	defer stream.Close()
  	stream.SetDeadline(time.Now().Add(rpcTimeout))
  
  	// Create the RPC client
  	cc := msgpackrpc.NewCodec(true, true, stream)
  	return msgpackrpc.CallWithCodec(cc, method, args, resp)
  }
docs: // RPC is used to perform an RPC