Implement streaming response for

TriggerUserPipeline RPC

Modify the TriggerUserPipeline RPC method to return a stream of
TriggerUserPipelineResponse messages instead of a single response.
Update the URL to include the :stream suffix, indicating the streaming
behavior of the endpoint.
The streaming response allows clients to receive pipeline results
incrementally as they become available, reducing latency and improving
real-time inference capabilities.

vdp/pipeline/v1beta/pipeline_public_service.proto

@@ -180,20 +180,21 @@ service PipelinePublicService {
     option (google.api.method_signature) = "name,inputs";
   }
 
- // Trigger a pipeline owned by a user
-//
-// Triggers the execution of a pipeline and streams the results back to the user.
-// This method is intended for real-time inference when low latency is of concern.
-//
-// The pipeline is identified by its resource name, formed by the parent user
-// and ID of the pipeline.
-//
-// The response is returned as a stream of data, allowing the client to receive
-// the results incrementally as they become available.
-//
-  // For more information, see [Trigger
-  // Pipeline](TODO: Add link).
-  rpc TriggerUserPipeline(TriggerUserPipelineRequest) returns (TriggerUserPipelineResponse) {
+
+  // Trigger a pipeline owned by a user
+  //
+  // Triggers the execution of a pipeline and streams the results back to the user.
+  // This method is intended for real-time inference when low latency is of concern.
+  //
+  // The pipeline is identified by its resource name, formed by the parent user
+  // and ID of the pipeline.
+  //
+  // The response is returned as a stream of data, allowing the client to receive
+  // the results incrementally as they become available.
+  //
+  // For more information, see [Run
+  // Pipeline](https://www.instill.tech/docs/vdp/run).
+  rpc TriggerUserPipelineStream(TriggerUserPipelineRequest) returns (stream TriggerUserPipelineResponse) {
     option (google.api.http) = {
       post: "/v1beta/{name=users/*/pipelines/*}/trigger:stream"
       body: "*"