diff --git a/client/grpcclient/grpc_client.go b/client/grpcclient/grpc_client.go index ced8d76..a0d5712 100644 --- a/client/grpcclient/grpc_client.go +++ b/client/grpcclient/grpc_client.go @@ -365,7 +365,7 @@ func (c *grpcClient) stream(ctx context.Context, address string, req client.Requ s, err := conn.NewStream( newCtx, &grpc.StreamDesc{ - StreamName: req.Service() + req.Method(), + StreamName: req.Method(), ClientStreams: true, ServerStreams: true, },