Limit number of running transformation threads

This commit is contained in:
Ivan Ivanov 2020-06-02 20:06:12 +03:00 committed by Will Norris
parent 731fa16921
commit bbd716c747
2 changed files with 15 additions and 0 deletions

View file

@ -735,6 +735,7 @@ func TestTransformingTransport(t *testing.T) {
tr := &TransformingTransport{
Transport: &testTransport{},
CachingClient: client,
limiter: make(chan struct{}, 1),
}
client.Transport = tr