renaming streamingcalls

grpc · Dec 18, 2024 · 1e7a099 · 1e7a099
1 parent fa74a99
commit 1e7a099
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
@@ -308,7 +308,7 @@ func (s) TestStaticPolicyEnd2End(t *testing.T) {
 				UnaryCallF: func(ctx context.Context, req *testpb.SimpleRequest) (*testpb.SimpleResponse, error) {
 					return &testpb.SimpleResponse{}, nil
 				},
-				StreamingInputCallF: func(stream testgrpc.TestService_StreamingInputCallServer) error {
+				ClientStreamingInputCall: func(stream testgrpc.TestService_StreamingInputCallServer) error {
 					for {
 						_, err := stream.Recv()
 						if err == io.EOF {
@@ -527,7 +527,7 @@ func (s) TestFileWatcherEnd2End(t *testing.T) {
 				UnaryCallF: func(ctx context.Context, req *testpb.SimpleRequest) (*testpb.SimpleResponse, error) {
 					return &testpb.SimpleResponse{}, nil
 				},
-				StreamingInputCallF: func(stream testgrpc.TestService_StreamingInputCallServer) error {
+				ClientStreamingInputCall: 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
-	StreamingInputCallF  func(stream testgrpc.TestService_StreamingInputCallServer) error
-	StreamingOutputCallF 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
+	ClientStreamingInputCall  func(stream testgrpc.TestService_StreamingInputCallServer) error
+	ClientStreamingOutputCall func(req *testpb.StreamingOutputCallRequest, stream testgrpc.TestService_StreamingOutputCallServer) error
 
 	// 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.StreamingInputCallF(stream)
+	return ss.ClientStreamingInputCall(stream)
 }
 
 // StreamingOutputCall is the handler for testpb.StreamingOutputCall
 func (ss *StubServer) StreamingOutputCall(req *testpb.StreamingOutputCallRequest, stream testgrpc.TestService_StreamingOutputCallServer) error {
-	return ss.StreamingOutputCallF(req, stream)
+	return ss.ClientStreamingOutputCall(req, stream)
 }
 
 // Start starts the server and creates a client connected to it.