diff options
Diffstat (limited to 'client')
| -rw-r--r-- | client/dial_test.go | 12 |
1 files changed, 6 insertions, 6 deletions
diff --git a/client/dial_test.go b/client/dial_test.go index b862b4c3e..e0870ee32 100644 --- a/client/dial_test.go +++ b/client/dial_test.go @@ -296,7 +296,7 @@ func TestDial_Correlation(t *testing.T) { } grpc_testing.RegisterTestServiceServer(grpcServer, svc) - go func() { assert.NoError(t, grpcServer.Serve(listener)) }() + go testhelper.MustServe(t, grpcServer, listener) defer grpcServer.Stop() ctx := testhelper.Context(t) @@ -332,7 +332,7 @@ func TestDial_Correlation(t *testing.T) { } grpc_testing.RegisterTestServiceServer(grpcServer, svc) - go func() { assert.NoError(t, grpcServer.Serve(listener)) }() + go testhelper.MustServe(t, grpcServer, listener) defer grpcServer.Stop() ctx := testhelper.Context(t) @@ -395,7 +395,7 @@ func TestDial_Tracing(t *testing.T) { } grpc_testing.RegisterTestServiceServer(grpcServer, svc) - go func() { require.NoError(t, grpcServer.Serve(listener)) }() + go testhelper.MustServe(t, grpcServer, listener) defer grpcServer.Stop() ctx := testhelper.Context(t) @@ -543,7 +543,7 @@ func startTCPListener(tb testing.TB, factory func(credentials.TransportCredentia address := fmt.Sprintf("%d", tcpPort) grpcServer := factory(insecure.NewCredentials()) - go grpcServer.Serve(listener) + go testhelper.MustServe(tb, grpcServer, listener) return func() { grpcServer.Stop() @@ -558,7 +558,7 @@ func startUnixListener(tb testing.TB, factory func(credentials.TransportCredenti require.NoError(tb, err) grpcServer := factory(insecure.NewCredentials()) - go grpcServer.Serve(listener) + go testhelper.MustServe(tb, grpcServer, listener) return func() { grpcServer.Stop() @@ -583,7 +583,7 @@ func startTLSListener(tb testing.TB, factory func(credentials.TransportCredentia MinVersion: tls.VersionTLS12, }), ) - go grpcServer.Serve(listener) + go testhelper.MustServe(tb, grpcServer, listener) return func() { grpcServer.Stop() |