diff --git a/transport/transport_test.go b/transport/transport_test.go index f58365a5..fcbd566c 100644 --- a/transport/transport_test.go +++ b/transport/transport_test.go @@ -308,6 +308,17 @@ func TestMaxConnectionIdle(t *testing.T) { }, } server, client := setUpWithOptions(t, 0, serverConfig, normal, ConnectOptions{}) + defer server.stop() + defer client.Close() + stream, err := client.NewStream(context.Background(), &CallHdr{Host: "localhost", Method: "foo.small"}) + if err != nil { + t.Fatalf("Client failed to create RPC request: %v", err) + } + stream.mu.Lock() + stream.rstStream = true + stream.mu.Unlock() + client.CloseStream() + // wait for server to see that closed stream and max age to send goaway after no new RPCs are mode } func TestKeepaliveClientClosesIdleTransport(t *testing.T) {