gofmt
This commit is contained in:
Родитель
7239e4afea
Коммит
453b255dda
|
@ -73,7 +73,7 @@ var (
|
|||
cancel_after_first_response: cancellation after receiving 1st message from the server.`)
|
||||
|
||||
// The test CA root cert file
|
||||
testCAFile = "testdata/ca.pem"
|
||||
testCAFile = "testdata/ca.pem"
|
||||
)
|
||||
|
||||
func main() {
|
||||
|
|
|
@ -242,7 +242,7 @@ func DoEmptyStream(tc testpb.TestServiceClient) {
|
|||
grpclog.Println("Emptystream done")
|
||||
}
|
||||
|
||||
// DoTimeoutSleepingServer performs an RPC on a sleep server which causes RPC timeout.
|
||||
// DoTimeoutSleepingServer performs an RPC on a sleep server which causes RPC timeout.
|
||||
func DoTimeoutOnSleepingServer(tc testpb.TestServiceClient) {
|
||||
ctx, _ := context.WithTimeout(context.Background(), 1*time.Millisecond)
|
||||
stream, err := tc.FullDuplexCall(ctx)
|
||||
|
@ -600,4 +600,3 @@ func (s *TestServer) HalfDuplexCall(stream testpb.TestService_HalfDuplexCallServ
|
|||
}
|
||||
return nil
|
||||
}
|
||||
|
||||
|
|
Загрузка…
Ссылка в новой задаче