cr, err := client.Watch.Watch(context.Background(), &v1.WatchRequest{
    TenantId:  "t1",
    SnapToken: "",
})
// handle stream response
for {
    res, err := cr.Recv()

    if err == io.EOF {
        break
    }

    // res.Changes
}

const permify = require("@permify/permify-node");
const {WatchResponse} = require("@permify/permify-node/dist/src/grpc/generated/base/v1/service");

function main() {
    const client = new permify.grpc.newClient({
        endpoint: "localhost:3478",
    });

    let res = client.watch.watch({
        tenantId: "t1",
        snapToken: ""
    });

    handle(res);
}

async function handle(res: AsyncIterable<WatchResponse>) {
    for await (const response of res) {
        // response.changes
    }
}

{
  "result": {
    "changes": {
      "snap_token": "<string>",
      "data_changes": [
        {
          "operation": "OPERATION_UNSPECIFIED",
          "tuple": {
            "entity": {
              "type": "<string>",
              "id": "<string>"
            },
            "relation": "<string>",
            "subject": {
              "type": "<string>",
              "id": "<string>",
              "relation": "<string>"
            }
          },
          "attribute": {
            "entity": {
              "type": "<string>",
              "id": "<string>"
            },
            "attribute": "<string>",
            "value": {
              "@type": "<string>"
            }
          }
        }
      ]
    }
  },
  "error": {
    "code": 123,
    "message": "<string>",
    "details": [
      {
        "@type": "<string>"
      }
    ]
  }
}

{
  "code": 123,
  "message": "<string>",
  "details": [
    {
      "@type": "<string>"
    }
  ]
}