Skip to content

Commit

Permalink
rename
Browse files Browse the repository at this point in the history
  • Loading branch information
arvindbr8 committed Dec 22, 2022
1 parent 54ce526 commit 64494e1
Show file tree
Hide file tree
Showing 2 changed files with 6 additions and 6 deletions.
4 changes: 2 additions & 2 deletions internal/transport/transport_test.go
Expand Up @@ -547,10 +547,10 @@ func (s) TestClientTransportDrainsAfterStreamIdExhausted(t *testing.T) {
Method: "foo.Small",
}
// override MaxStreamIDForTesting.
originalMaxStreamId := MaxStreamIDForTesting
originalMaxStreamID := MaxStreamIDForTesting
MaxStreamIDForTesting = 1
defer func() {
MaxStreamIDForTesting = originalMaxStreamId
MaxStreamIDForTesting = originalMaxStreamID
}()

ctx, ctxCancel := context.WithTimeout(context.Background(), defaultTestTimeout)
Expand Down
8 changes: 4 additions & 4 deletions test/end2end_test.go
Expand Up @@ -7073,7 +7073,7 @@ func (s) TestClientTransportRestartsAfterStreamIdExhausted(t *testing.T) {

client := testpb.NewTestServiceClient(cc)

createStreamAndRecv := func(ctx context.Context) {
createStreamAndRecv := func() {
stream, err := client.FullDuplexCall(ctx)
if err != nil {
t.Fatalf("creating FullDuplex stream: %v", err)
Expand All @@ -7084,9 +7084,9 @@ func (s) TestClientTransportRestartsAfterStreamIdExhausted(t *testing.T) {
}

// creating FullDuplexCall stream #1.
createStreamAndRecv(ctx)
createStreamAndRecv()
// creating FullDuplexCall stream #2.
createStreamAndRecv(ctx)
createStreamAndRecv()

// verifying creation of new conn channel.
val, err := lisWrap.NewConnCh.Receive(ctx)
Expand All @@ -7096,7 +7096,7 @@ func (s) TestClientTransportRestartsAfterStreamIdExhausted(t *testing.T) {
conn1 := val.(*testutils.ConnWrapper)

// this stream should be created in a new conn channel.
createStreamAndRecv(ctx)
createStreamAndRecv()

// verifying a new conn channel is created.
if _, err = lisWrap.NewConnCh.Receive(ctx); err != nil {
Expand Down

0 comments on commit 64494e1

Please sign in to comment.