renaming client and server handlers

grpc · Dec 20, 2024 · ecdab23 · ecdab23
1 parent 924a9e7
commit ecdab23
Show file tree

Hide file tree

Showing 2 changed files with 9 additions and 9 deletions.
diff --git a/authz/grpc_authz_end2end_test.go b/authz/grpc_authz_end2end_test.go
@@ -304,7 +304,7 @@ func (s) TestStaticPolicyEnd2End(t *testing.T) {
 				UnaryCallF: func(ctx context.Context, req *testpb.SimpleRequest) (*testpb.SimpleResponse, error) {
 					return &testpb.SimpleResponse{}, nil
 				},
-				ClientStreamingInputCall: func(stream testgrpc.TestService_StreamingInputCallServer) error {
+				StreamingInputCallF: func(stream testgrpc.TestService_StreamingInputCallServer) error {
 					for {
 						_, err := stream.Recv()
 						if err == io.EOF {
@@ -518,7 +518,7 @@ func (s) TestFileWatcherEnd2End(t *testing.T) {
 				UnaryCallF: func(ctx context.Context, req *testpb.SimpleRequest) (*testpb.SimpleResponse, error) {
 					return &testpb.SimpleResponse{}, nil
 				},
-				ClientStreamingInputCall: func(stream testgrpc.TestService_StreamingInputCallServer) error {
+				StreamingInputCallF: func(stream testgrpc.TestService_StreamingInputCallServer) error {
 					for {
 						_, err := stream.Recv()
 						if err == io.EOF {

diff --git a/internal/stubserver/stubserver.go b/internal/stubserver/stubserver.go
@@ -56,11 +56,11 @@ type StubServer struct {
 	testgrpc.TestServiceServer
 
 	// Customizable implementations of server handlers.
-	EmptyCallF                func(ctx context.Context, in *testpb.Empty) (*testpb.Empty, error)
-	UnaryCallF                func(ctx context.Context, in *testpb.SimpleRequest) (*testpb.SimpleResponse, error)
-	FullDuplexCallF           func(stream testgrpc.TestService_FullDuplexCallServer) error
-	ClientStreamingInputCall  func(stream testgrpc.TestService_StreamingInputCallServer) error
-	ClientStreamingOutputCall func(req *testpb.StreamingOutputCallRequest, stream testgrpc.TestService_StreamingOutputCallServer) error
+	EmptyCallF           func(ctx context.Context, in *testpb.Empty) (*testpb.Empty, error)
+	UnaryCallF           func(ctx context.Context, in *testpb.SimpleRequest) (*testpb.SimpleResponse, error)
+	FullDuplexCallF      func(stream testgrpc.TestService_FullDuplexCallServer) error
+	StreamingInputCallF  func(stream testgrpc.TestService_StreamingInputCallServer) error                                          // ClientStreaming
+	StreamingOutputCallF func(req *testpb.StreamingOutputCallRequest, stream testgrpc.TestService_StreamingOutputCallServer) error // ServerStreaming
 
 	// A client connected to this service the test may use.  Created in Start().
 	Client testgrpc.TestServiceClient
@@ -105,12 +105,12 @@ func (ss *StubServer) FullDuplexCall(stream testgrpc.TestService_FullDuplexCallS
 
 // StreamingInputCall is the handler for testpb.StreamingInputCall
 func (ss *StubServer) StreamingInputCall(stream testgrpc.TestService_StreamingInputCallServer) error {
-	return ss.ClientStreamingInputCall(stream)
+	return ss.StreamingInputCallF(stream)
 }
 
 // StreamingOutputCall is the handler for testpb.StreamingOutputCall
 func (ss *StubServer) StreamingOutputCall(req *testpb.StreamingOutputCallRequest, stream testgrpc.TestService_StreamingOutputCallServer) error {
-	return ss.ClientStreamingOutputCall(req, stream)
+	return ss.StreamingOutputCallF(req, stream)
 }
 
 // Start starts the server and creates a client connected to it.