Move consumeSlow() under test utils
Signed-off-by: Tõnis Tiigi <tonistiigi@gmail.com> (github: tonistiigi)
This commit is contained in:
parent
b63a254522
commit
8a81c46272
|
@ -2474,19 +2474,3 @@ func TestRunSlowStdoutConsumer(t *testing.T) {
|
||||||
|
|
||||||
logDone("run - slow consumer")
|
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)
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
|
@ -253,3 +253,19 @@ func makeRandomString(n int) string {
|
||||||
}
|
}
|
||||||
return string(b)
|
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)
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
Loading…
Reference in New Issue