diff --git a/test/end2end_test.go b/test/end2end_test.go index d47af7ed..644c3857 100644 --- a/test/end2end_test.go +++ b/test/end2end_test.go @@ -1063,11 +1063,12 @@ func testExceedMaxStreamsLimit(t *testing.T, e env) { done := make(chan struct{}) ch := make(chan int) go func() { + timer := time.After(5 * time.Second) for { select { case <-time.After(5 * time.Millisecond): ch <- 0 - case <-time.After(5 * time.Second): + case <-timer: close(done) return } @@ -1077,6 +1078,7 @@ func testExceedMaxStreamsLimit(t *testing.T, e env) { for { select { case <-ch: + //grpclog.Println("start a stream...") ctx, _ := context.WithTimeout(context.Background(), time.Second) if _, err := tc.StreamingInputCall(ctx); err != nil { if grpc.Code(err) == codes.DeadlineExceeded {