Skip to content

Commit 43a4a84

Browse files
internal/balancer/clusterimpl: replace testpb with testgrpc (#8188)
1 parent d8924ac commit 43a4a84

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

xds/internal/balancer/clusterimpl/tests/balancer_test.go

+2-2
Original file line numberDiff line numberDiff line change
@@ -383,7 +383,7 @@ func (s) TestCircuitBreaking(t *testing.T) {
383383
EmptyCallF: func(ctx context.Context, _ *testpb.Empty) (*testpb.Empty, error) {
384384
return &testpb.Empty{}, nil
385385
},
386-
FullDuplexCallF: func(stream testpb.TestService_FullDuplexCallServer) error {
386+
FullDuplexCallF: func(stream testgrpc.TestService_FullDuplexCallServer) error {
387387
for {
388388
if _, err := stream.Recv(); err != nil {
389389
return err
@@ -478,7 +478,7 @@ func (s) TestCircuitBreakingLogicalDNS(t *testing.T) {
478478
EmptyCallF: func(ctx context.Context, _ *testpb.Empty) (*testpb.Empty, error) {
479479
return &testpb.Empty{}, nil
480480
},
481-
FullDuplexCallF: func(stream testpb.TestService_FullDuplexCallServer) error {
481+
FullDuplexCallF: func(stream testgrpc.TestService_FullDuplexCallServer) error {
482482
for {
483483
if _, err := stream.Recv(); err != nil {
484484
return err

0 commit comments

Comments
 (0)