GRPC integration test Proto and Controller updated with streaming definitions to test

Author: anton-alation

integration/microservices/src/grpc/grpc.controller.ts

@@ -1,5 +1,5 @@
 import { Body, Controller, HttpCode, Post } from '@nestjs/common';
-import { Client, ClientGrpc, GrpcMethod, Transport } from '@nestjs/microservices';
+import { Client, ClientGrpc, GrpcMethod, GrpcStream, Transport } from '@nestjs/microservices';
 import { join } from 'path';
 import { Observable, of } from 'rxjs';
 
@@ -27,4 +27,14 @@ export class GrpcController {
       result: data.reduce((a, b) => a + b),
     });
   }
+
+  @GrpcStream('Math')
+  async sumStream(stream: any) {
+
+    stream.on('data', (msg) => {
+      console.log('DATA@!', msg);
+      stream.write({result: 1});
+    });
+
+  }
 }

integration/microservices/src/grpc/math.proto

@@ -3,7 +3,8 @@ syntax = "proto3";
 package math;
 
 service Math {
-  rpc Sum (RequestSum) returns (SumResult) {}
+  rpc Sum (RequestSum) returns (SumResult);
+  rpc SumStream(stream RequestSum) returns(stream SumResult);
 }
 
 message SumResult {