diff --git a/integration-cli/docker_cli_run_test.go b/integration-cli/docker_cli_run_test.go index 072c6f6b44..eb174ad974 100644 --- a/integration-cli/docker_cli_run_test.go +++ b/integration-cli/docker_cli_run_test.go @@ -2474,19 +2474,3 @@ func TestRunSlowStdoutConsumer(t *testing.T) { logDone("run - slow consumer") } - -func consumeSlow(reader io.Reader, chunkSize int, interval time.Duration) (n int, err error) { - buffer := make([]byte, chunkSize) - for { - var readBytes int - readBytes, err = reader.Read(buffer) - n += readBytes - if err != nil { - if err == io.EOF { - err = nil - } - return - } - time.Sleep(interval) - } -} diff --git a/integration-cli/utils.go b/integration-cli/utils.go index e99e45591b..3d15f66f1d 100644 --- a/integration-cli/utils.go +++ b/integration-cli/utils.go @@ -253,3 +253,19 @@ func makeRandomString(n int) string { } return string(b) } + +func consumeSlow(reader io.Reader, chunkSize int, interval time.Duration) (n int, err error) { + buffer := make([]byte, chunkSize) + for { + var readBytes int + readBytes, err = reader.Read(buffer) + n += readBytes + if err != nil { + if err == io.EOF { + err = nil + } + return + } + time.Sleep(interval) + } +}