diff --git a/interceptors/client.go b/interceptors/client.go index 97f2ad2a..2b059015 100644 --- a/interceptors/client.go +++ b/interceptors/client.go @@ -46,9 +46,9 @@ func StreamClientInterceptor(reportable ClientReportable) grpc.StreamClientInter type monitoredClientStream struct { grpc.ClientStream - startTime time.Time + startTime time.Time hasServerStream bool - reporter Reporter + reporter Reporter } func (s *monitoredClientStream) SendMsg(m any) error { @@ -75,5 +75,5 @@ func (s *monitoredClientStream) RecvMsg(m any) error { } else { s.reporter.PostCall(err, time.Since(s.startTime)) } - return err + return err } diff --git a/interceptors/client_test.go b/interceptors/client_test.go index d1c4079e..252cb0bb 100644 --- a/interceptors/client_test.go +++ b/interceptors/client_test.go @@ -338,7 +338,6 @@ func (s *ClientInterceptorTestSuite) TestBiStreamingReporting() { }}) } - func (s *ClientInterceptorTestSuite) TestClientStream() { ss, err := s.testClient.PingClientStream(s.ctx) require.NoError(s.T(), err) diff --git a/testing/testpb/pingservice.go b/testing/testpb/pingservice.go index 65615599..42908388 100644 --- a/testing/testpb/pingservice.go +++ b/testing/testpb/pingservice.go @@ -81,7 +81,6 @@ func (s *TestPingService) PingStream(stream TestService_PingStreamServer) error return nil } - func (s *TestPingService) PingClientStream(stream TestService_PingClientStreamServer) error { count := 0 for { diff --git a/testing/testpb/test.pb.go b/testing/testpb/test.pb.go index 15f902d7..5c3cd96a 100644 --- a/testing/testpb/test.pb.go +++ b/testing/testpb/test.pb.go @@ -7,10 +7,11 @@ package testpb import ( - protoreflect "google.golang.org/protobuf/reflect/protoreflect" - protoimpl "google.golang.org/protobuf/runtime/protoimpl" reflect "reflect" sync "sync" + + protoreflect "google.golang.org/protobuf/reflect/protoreflect" + protoimpl "google.golang.org/protobuf/runtime/protoimpl" ) const (