feat: ttheader streaming

codec/protobuf/echo-grpc.proto

@@ -23,6 +23,7 @@ service Echo {
 // === streaming ===
 //----------------------service-------------------
 service SEcho {
+  // bidirectional
   rpc echo (stream Request) returns (stream Response) {
   }
 }

codec/protobuf/echo-kitex.proto

@@ -23,6 +23,7 @@ service Echo {
 // === streaming ===
 //----------------------service-------------------
 service SEcho {
+  // bidirectional
   rpc echo (stream Request) returns (stream Response) {
   }
 }

codec/thrift/echo.thrift

@@ -49,3 +49,7 @@ service EchoServer {
     Response Echo(1: Request req)
     ComplexResponse EchoComplex(1: ComplexRequest req)(api.post = '/echo/complex/:action', api.baseurl = 'example.com', api.param = 'true', api.serializer = 'json')
 }
+
+service StreamServer {
+    Response Echo(1: Request req) (streaming.mode="bidirectional"),
+}

codec/thrift/gen_code.sh

@@ -1 +1 @@
-kitex -module github.com/cloudwego/kitex-benchmark ./echo.thrift
+kitex -module -stream-v2 github.com/cloudwego/kitex-benchmark ./echo.thrift