Streaming operations

1
syntax = "proto3";
2
3
package userservice.v1;
4
5
service UserService {
6
  rpc StreamEvents(StreamEventsRequest) returns (stream Event) {
7
    option (x_fern_streaming) = '{
8
      "type": "server_streaming",
9
      "termination": "client_closes"
10
    }';
11
  }
12
  
13
  rpc UploadData(stream UploadDataRequest) returns (UploadResult) {
14
    option (x_fern_streaming) = '{
15
      "type": "client_streaming",
16
      "termination": "client_closes"
17
    }';
18
  }
19
  
20
  rpc Chat(stream ChatMessage) returns (stream ChatMessage) {
21
    option (x_fern_streaming) = '{
22
      "type": "bidirectional_streaming",
23
      "termination": "either_closes"
24
    }';
25
  }
26
}