Method createStreamCallMethod

packages/microservices/server/server-grpc.ts:518–546

(
    methodHandler: Function,
    isResponseStream: boolean,
  )

  }

  public createStreamCallMethod(
    methodHandler: Function,
    isResponseStream: boolean,
  ) {
    return async (
      call: GrpcCall,
      callback: (err: unknown, value: unknown) => void,
    ) => {
      return this.onProcessingStartHook(
        this.transportId,
        { ...call, operationId: methodHandler.name } as any,
        async () => {
          let handlerStream: Observable<any>;
          if (isResponseStream) {
            handlerStream = this.transformToObservable(
              await methodHandler(call),
            );
          } else {
            handlerStream = this.transformToObservable(
              await methodHandler(call, callback),
            );
          }
          await lastValueFrom(handlerStream).finally(() => {
            this.onProcessingEndHook?.(this.transportId, call.request);
          });
        },
      );
    };
  }

  public async close(): Promise<void> {
    if (this.grpcClient) {